import requests

url = "https://{FUSION_HOST}/job-launcher/launcher/status"

payload = {
    "state": "finished",
    "jobId": "hhzitrwancwv",
    "jobConfig": {
        "type": "aggregation",
        "id": "api-test-app_click_signals_aggregation",
        "inputCollection": "api-test-app_signals",
        "sourceCatchup": True,
        "sourceRemove": False,
        "sql": "WITH sigs_with_filters AS ( SELECT c.query as query, c.doc_id, q.filters_s as filters, c.type, c.ref_time, coalesce(c.count_i,1) as count_i, c.timestamp_tdt, greatest(coalesce(c.weight_d,0.1),0.0) as weight_d FROM api-test-app_signals c LEFT JOIN (SELECT id, filters_s FROM api-test-app_signals WHERE type='response') q ON q.id = c.fusion_query_id WHERE c.type IN ('click','cart','purchase') AND c.timestamp_tdt >= c.catchup_timestamp_tdt ), signal_type_groups AS ( SELECT SUM(count_i) AS typed_aggr_count_i, query, doc_id, type, filters, time_decay(count_i, timestamp_tdt, \"30 days\", ref_time, weight_d) AS typed_weight_d FROM sigs_with_filters GROUP BY doc_id, query, filters, type ) SELECT concat_ws('|', query, doc_id, filters) as id, SUM(typed_aggr_count_i) AS aggr_count_i, query AS query_s, query AS query_t, doc_id AS doc_id_s, filters AS filters_s, SPLIT(filters, ' \\$ ') AS filters_ss, weighted_sum(typed_weight_d, type, 'click:1.0,cart:10.0,purchase:25.0') AS weight_d FROM signal_type_groups GROUP BY query, doc_id, filters",
        "rollupSql": "SELECT concat_ws('|', query_s, doc_id_s, filters_s) as id,
  query_s,
  query_s as query_t,
  doc_id_s,
  filters_s,
  first(aggr_type_s) AS aggr_type_s,
  SPLIT(filters_s, ' \\$ ') AS filters_ss,
  SUM(weight_d) AS weight_d,
  SUM(aggr_count_i) AS aggr_count_i
  FROM api-test-app_signals_aggr
  GROUP BY query_s, doc_id_s, filters_s",
        "referenceTime": "2025-10-17T18:56:14.660Z",
        "skipCheckEnabled": True,
        "readOptions": [
            {
                "key": "splits_per_shard",
                "value": "4"
            }
        ],
        "skipJobIfSignalsEmpty": True,
        "parameters": [
            {
                "key": "signalTypeWeights",
                "value": "click:1.0,cart:10.0,purchase:25.0"
            },
            {
                "key": "signalTypes",
                "value": "_regex/signalTypeWeights/([\w\-\.]*):([\d\.\-]*)(,|$)/'$1'$3/g"
            }
        ],
        "selectQuery": "*:*",
        "outputCollection": "api-test-app_signals_aggr",
        "useNaturalKey": True,
        "optimizeSegments": 0,
        "dataFormat": "solr",
        "sparkSQL": "SELECT * from spark_input",
        "sparkPartitions": 200
    },
    "hostname": "driver-api-test-app-click-signal-sjnamxwxsyhq",
    "result": {
        "jobConfigId": "api-test-app_click_signals_aggregation",
        "jobRunId": "sjnamxwxsyhq",
        "aggrClass": "SQL",
        "query": "WITH sigs_with_filters AS (SELECT c.query as query, c.doc_id, q.filters_s as filters, c.type, c.ref_time, coalesce(c.count_i,1) as count_i, c.timestamp_tdt, greatest(coalesce(c.weight_d,0.1),0.0) as weight_d FROM api_test_app_signals c LEFT JOIN (SELECT id, filters_s FROM api_test_app_signals WHERE type='response') q ON q.id = c.fusion_query_id WHERE c.type IN ('click','cart','purchase') AND c.timestamp_tdt >= c.catchup_timestamp_tdt ), signal_type_groups AS (SELECT SUM(count_i) AS typed_aggr_count_i, query, doc_id, type, filters, time_decay(count_i, timestamp_tdt, \"30 days\", ref_time, weight_d) AS typed_weight_d FROM sigs_with_filters GROUP BY doc_id, query, filters, type) SELECT concat_ws('|', query, doc_id, filters) as id, SUM(typed_aggr_count_i) AS aggr_count_i, query AS query_s, query AS query_t, doc_id AS doc_id_s, filters AS filters_s, SPLIT(filters, ' \\$ ') AS filters_ss, weighted_sum(typed_weight_d, type, 'click:1.0,cart:10.0,purchase:25.0') AS weight_d FROM signal_type_groups GROUP BY query, doc_id, filters",
        "state": "finished",
        "aggregated": 0,
        "applicationId": "spark-0424dda9215441c0b232210af1d7cb67",
        "podId": "driver-api-test-app-click-signal-sjnamxwxsyhq",
        "aggr_type_s": "click@doc_id,filters,query"
    },
    "startTime": "2025-10-16T19:49:15.106Z",
    "endTime": "2025-10-16T19:49:42.276Z",
    "duration": 27170
}
headers = {"Content-Type": "application/json"}

response = requests.post(url, json=payload, headers=headers)

print(response.text)