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)