Changeset View

Standalone View

Show First 20 Lines • Show All 772 Lines • ▼ Show 20 Lines	) -> Dict[str, Any]:
max_ts_unix = int(max_ts.timestamp()) * 1000		max_ts_unix = int(max_ts.timestamp()) * 1000

save_task_status = _save_task_status[task["status"]]		save_task_status = _save_task_status[task["status"]]
priority = "3" if save_task_status == SAVE_TASK_FAILED else "6"		priority = "3" if save_task_status == SAVE_TASK_FAILED else "6"

query = {		query = {
"bool": {		"bool": {
"must": [		"must": [
{"match_phrase": {"priority": {"query": priority}}},		{"match_phrase": {"syslog.priority": {"query": priority}}},
{"match_phrase": {"swh_task_id": {"query": task_run["backend_id"]}}},		{
		"match_phrase": {
		"journald.custom.swh_task_id": {"query": task_run["backend_id"]}
		}
		},
{		{
"range": {		"range": {
"@timestamp": {		"@timestamp": {
"gte": min_ts_unix,		"gte": min_ts_unix,
"lte": max_ts_unix,		"lte": max_ts_unix,
"format": "epoch_millis",		"format": "epoch_millis",
}		}
}		}
▲ Show 20 Lines • Show All 145 Lines • Show Last 20 Lines