proto1_to_proto2
Convert Task message protocol 1 arguments to protocol 2.
def proto1_to_proto2(
message: Message,
body: dict
) - > Tuple
Convert Task message protocol 1 arguments to protocol 2.
Parameters
| Name | Type | Description |
|---|---|---|
| message | Message | The incoming message object containing metadata and headers |
| body | dict | The message body dictionary containing task arguments, keyword arguments, and execution options |
Returns
| Type | Description |
|---|---|
Tuple | A tuple containing (body, headers, already_decoded_status, utc) |