# Subscriptions ## List Event Subscriptions `queues.subscriptions.list(SubscriptionListParams**kwargs) -> SyncV4PagePaginationArray[SubscriptionListResponse]` **get** `/accounts/{account_id}/event_subscriptions/subscriptions` Get a paginated list of event subscriptions with optional sorting and filtering ### Parameters - `account_id: str` A Resource identifier. - `direction: Optional[Literal["asc", "desc"]]` Sort direction - `"asc"` - `"desc"` - `order: Optional[Literal["created_at", "name", "enabled", "source"]]` Field to sort by - `"created_at"` - `"name"` - `"enabled"` - `"source"` - `page: Optional[int]` Page number for pagination - `per_page: Optional[int]` Number of items per page ### Returns - `class SubscriptionListResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Example ```python import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) page = client.queues.subscriptions.list( account_id="023e105f4ecef8ad9ca31a8372d0c353", ) page = page.result[0] print(page.id) ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": [ { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } } ], "result_info": { "count": 0, "page": 0, "per_page": 0, "total_count": 0, "total_pages": 0 }, "success": true } ``` ## Get Event Subscription `queues.subscriptions.get(strsubscription_id, SubscriptionGetParams**kwargs) -> SubscriptionGetResponse` **get** `/accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}` Get details about an existing event subscription ### Parameters - `account_id: str` A Resource identifier. - `subscription_id: str` A Resource identifier. ### Returns - `class SubscriptionGetResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Example ```python import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) subscription = client.queues.subscriptions.get( subscription_id="023e105f4ecef8ad9ca31a8372d0c353", account_id="023e105f4ecef8ad9ca31a8372d0c353", ) print(subscription.id) ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } }, "success": true } ``` ## Create Event Subscription `queues.subscriptions.create(SubscriptionCreateParams**kwargs) -> SubscriptionCreateResponse` **post** `/accounts/{account_id}/event_subscriptions/subscriptions` Create a new event subscription for a queue ### Parameters - `account_id: str` A Resource identifier. - `destination: Optional[Destination]` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: Optional[bool]` Whether the subscription is active - `events: Optional[SequenceNotStr[str]]` List of event types this subscription handles - `name: Optional[str]` Name of the subscription - `source: Optional[Source]` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Returns - `class SubscriptionCreateResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Example ```python import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) subscription = client.queues.subscriptions.create( account_id="023e105f4ecef8ad9ca31a8372d0c353", ) print(subscription.id) ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } }, "success": true } ``` ## Update Event Subscription `queues.subscriptions.update(strsubscription_id, SubscriptionUpdateParams**kwargs) -> SubscriptionUpdateResponse` **patch** `/accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}` Update an existing event subscription ### Parameters - `account_id: str` A Resource identifier. - `subscription_id: str` A Resource identifier. - `destination: Optional[Destination]` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: Optional[bool]` Whether the subscription is active - `events: Optional[SequenceNotStr[str]]` List of event types this subscription handles - `name: Optional[str]` Name of the subscription ### Returns - `class SubscriptionUpdateResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Example ```python import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) subscription = client.queues.subscriptions.update( subscription_id="023e105f4ecef8ad9ca31a8372d0c353", account_id="023e105f4ecef8ad9ca31a8372d0c353", ) print(subscription.id) ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } }, "success": true } ``` ## Delete Event Subscription `queues.subscriptions.delete(strsubscription_id, SubscriptionDeleteParams**kwargs) -> SubscriptionDeleteResponse` **delete** `/accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}` Delete an existing event subscription ### Parameters - `account_id: str` A Resource identifier. - `subscription_id: str` A Resource identifier. ### Returns - `class SubscriptionDeleteResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Example ```python import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) subscription = client.queues.subscriptions.delete( subscription_id="023e105f4ecef8ad9ca31a8372d0c353", account_id="023e105f4ecef8ad9ca31a8372d0c353", ) print(subscription.id) ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } }, "success": true } ``` ## Domain Types ### Subscription List Response - `class SubscriptionListResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Subscription Get Response - `class SubscriptionGetResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Subscription Create Response - `class SubscriptionCreateResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Subscription Update Response - `class SubscriptionUpdateResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow ### Subscription Delete Response - `class SubscriptionDeleteResponse: …` - `id: str` Unique identifier for the subscription - `created_at: datetime` When the subscription was created - `destination: Destination` Destination configuration for the subscription - `queue_id: str` ID of the target queue - `type: Literal["queues.queue"]` Type of destination - `"queues.queue"` - `enabled: bool` Whether the subscription is active - `events: List[str]` List of event types this subscription handles - `modified_at: datetime` When the subscription was last modified - `name: str` Name of the subscription - `source: Source` Source configuration for the subscription - `class SourceMqEventSourceImages: …` - `type: Optional[Literal["images"]]` Type of source - `"images"` - `class SourceMqEventSourceKV: …` - `type: Optional[Literal["kv"]]` Type of source - `"kv"` - `class SourceMqEventSourceR2: …` - `type: Optional[Literal["r2"]]` Type of source - `"r2"` - `class SourceMqEventSourceSuperSlurper: …` - `type: Optional[Literal["superSlurper"]]` Type of source - `"superSlurper"` - `class SourceMqEventSourceVectorize: …` - `type: Optional[Literal["vectorize"]]` Type of source - `"vectorize"` - `class SourceMqEventSourceWorkersAIModel: …` - `model_name: Optional[str]` Name of the Workers AI model - `type: Optional[Literal["workersAi.model"]]` Type of source - `"workersAi.model"` - `class SourceMqEventSourceWorkersBuildsWorker: …` - `type: Optional[Literal["workersBuilds.worker"]]` Type of source - `"workersBuilds.worker"` - `worker_name: Optional[str]` Name of the worker - `class SourceMqEventSourceWorkflowsWorkflow: …` - `type: Optional[Literal["workflows.workflow"]]` Type of source - `"workflows.workflow"` - `workflow_name: Optional[str]` Name of the workflow