Module payload 

Payload types for Coordinator and Step tasks.

These are serialized as JSON and stored in AQ TaskPayload. The multiplexed handler (Sprint 4) uses TaskType to route execution.

Structs

CoordinatorPayload

Payload for the Coordinator task. Contains everything needed to orchestrate a FlowRun.

StepPayload

Payload for a Step task. Contains everything a Step handler needs to invoke a connector or execute a transform.

Enums

TaskType

Discriminator used by the multiplexed handler to route execution.

Constants

PAYLOAD_CONTENT_TYPE

JSON content type used for all payloads.