Skip to main content

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​

NameTypeDescription
messageMessageThe incoming message object containing metadata and headers
bodydictThe message body dictionary containing task arguments, keyword arguments, and execution options

Returns​

TypeDescription
TupleA tuple containing (body, headers, already_decoded_status, utc)