1from apify_client import ApifyClient
2
3
4
5client = ApifyClient("<YOUR_API_TOKEN>")
6
7
8run_input = {
9 "sender_jsonl": """{\"attempt_no\": 1, \"delivery_id\": \"d1\", \"event_id\": \"evt-1\", \"http_status\": 503, \"idempotency_key\": \"evt-1\", \"payload_sha256\": \"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa\", \"sent_at\": \"2026-09-13T10:00:00Z\"}\r
10{\"attempt_no\": 2, \"delivery_id\": \"d2\", \"event_id\": \"evt-1\", \"http_status\": 503, \"idempotency_key\": \"evt-1\", \"payload_sha256\": \"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa\", \"sent_at\": \"2026-09-13T10:01:00Z\"}\r
11{\"attempt_no\": 1, \"delivery_id\": \"d3\", \"event_id\": \"evt-2\", \"http_status\": 200, \"idempotency_key\": \"evt-2\", \"payload_sha256\": \"bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb\", \"sent_at\": \"2026-09-13T10:00:00Z\"}\r
12""",
13 "receiver_jsonl": """{\"event_id\": \"evt-2\", \"idempotency_key\": \"evt-2\", \"outcome\": \"succeeded\", \"payload_sha256\": \"bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb\", \"processing_id\": \"p1\", \"received_at\": \"2026-09-13T10:00:02Z\"}\r
14""",
15 "policy_json": """{\r
16 \"max_attempts\": 3,\r
17 \"retryable_http_statuses\": [\r
18 408,\r
19 429,\r
20 500,\r
21 502,\r
22 503,\r
23 504\r
24 ],\r
25 \"schema_version\": \"webhook-reconciliation-policy@1\"\r
26}\r
27""",
28}
29
30
31run = client.actor("biztoolsus/webhook-delivery-reconciliation").call(run_input=run_input)
32
33
34print(f"💾 Check your data here: https://console.apify.com/storage/datasets/{run.default_dataset_id}")
35for item in client.dataset(run.default_dataset_id).iterate_items():
36 print(item)
37
38