fix: Worker should only fetch async jobs

trapdata/antenna/client.py

@@ -2,7 +2,11 @@
 
 import requests
 
-from trapdata.antenna.schemas import AntennaJobsListResponse, AntennaTaskResult
+from trapdata.antenna.schemas import (
+    AntennaJobsListResponse,
+    AntennaTaskResult,
+    JobDispatchMode,
+)
 from trapdata.api.utils import get_http_session
 from trapdata.common.logs import logger
 
@@ -31,6 +35,7 @@ def get_jobs(
                 "pipeline__slug": pipeline_slug,
                 "ids_only": 1,
                 "incomplete_only": 1,
+                "dispatch_mode": JobDispatchMode.ASYNC_API,  # Only fetch async_api jobs
             }
 
             resp = session.get(url, params=params, timeout=30)

trapdata/antenna/schemas.py

@@ -85,3 +85,21 @@ class AsyncPipelineRegistrationResponse(pydantic.BaseModel):
         default=None,
         description="ID of the processing service that was created or updated",
     )
+
+
+class JobDispatchMode(str):
+    """
+    How a job dispatches its tasks.
+
+    External processing services should only be concerned with
+    jobs with dispatch_mode=async_api
+
+    Other job types will not have any tasks to fetch from the tasks endpoint and will
+    fail if you try to post results for them.
+
+    This mirrors the JobDispatchMode enum in the Antenna server.
+    """
+
+    INTERNAL = "internal"
+    SYNC_API = "sync_api"
+    ASYNC_API = "async_api"