pydocket_client_quickstart_job_submission_to_queue.py

1from pydocket import Docket
2
3# Initialize the Docket client
4# Assumes a Docket server is running on localhost:8080
5docket = Docket(host="localhost", port=8080)
6
7# Define a simple job payload
8job_data = {
9    "task": "send_email",
10    "payload": {
11        "to": "user@example.com",
12        "subject": "Hello from Pydocket",
13        "body": "This is a test job."
14    }
15}
16
17# Submit the job to a queue named 'default'
18job_id = docket.push("default", job_data)
19
20print(f"Successfully submitted job with ID: {job_id}")