temporalio.worker._workflow._CommandAwareDataConverter

class documentation

class _CommandAwareDataConverter(temporalio.converter.DataConverter): (source)

Constructor: _CommandAwareDataConverter.create(instance, context_free_dc, workflow_context_dc, workflow_context)

View In Hierarchy

Data converter that resolves serialization context per-command.

Responds to the context variable set by _command_aware_visitor.CommandAwarePayloadVisitor.

Static Method create Undocumented
Async Method _decode_payload_sequence Codec decode only.
Async Method _encode_payload_sequence Codec encode only.
Async Method _external_retrieve_payload_sequence External storage retrieve only.
Async Method _external_store_payload_sequence External storage store, then validate payload limits.
Method _get_current_dc Undocumented
Method _validate_payload_limits Undocumented
Class Variable _ca_context_free_dc Undocumented
Class Variable _ca_instance Undocumented
Class Variable _ca_workflow_context Undocumented
Class Variable _ca_workflow_context_dc Undocumented

Inherited from DataConverter:

Method __post_init__ Undocumented
Async Method decode Decode payloads into values.
Async Method decode_failure Decode and convert failure.
Async Method decode_wrapper decode for the temporalio.api.common.v1.Payloads wrapper.
Async Method encode Encode values into payloads.
Async Method encode_failure Convert and encode failure.
Async Method encode_wrapper encode for the temporalio.api.common.v1.Payloads wrapper.
Method with_context Return an instance with context set on the component converters.
Class Variable default Singleton default data converter.
Class Variable external_storage Options for external storage. If None, external storage is disabled.
Class Variable failure_converter Failure converter created from the failure_converter_class.
Class Variable payload_codec Optional codec for encoding payload bytes.
Class Variable payload_converter Payload converter created from the payload_converter_class.
Class Variable payload_limits Settings for payload size limits.
Static Method _validate_limits Undocumented
Async Method _decode_memo Undocumented
Async Method _decode_memo_field Undocumented
Async Method _encode_memo Undocumented
Async Method _encode_memo_existing Undocumented
Async Method _transform_inbound_payload Undocumented
Async Method _transform_inbound_payloads Undocumented
Async Method _transform_outbound_payload Undocumented
Async Method _transform_outbound_payloads Undocumented
Method _with_contexts Return an instance with both serialization and store contexts applied.
Method _with_payload_error_limits Undocumented
Method _with_store_context Return an instance with store_ctx bound into external_storage.
Class Variable _payload_error_limits Server-reported limits for payloads.
Property _decode_payload_has_effect Undocumented
def create(instance: WorkflowInstance, context_free_dc: temporalio.converter.DataConverter, workflow_context_dc: temporalio.converter.DataConverter, workflow_context: temporalio.converter.WorkflowSerializationContext) -> _CommandAwareDataConverter: (source)

Undocumented

async def _decode_payload_sequence(self, payloads: Sequence[temporalio.api.common.v1.Payload]) -> list[temporalio.api.common.v1.Payload]: (source)
overrides temporalio.converter.DataConverter._decode_payload_sequence

Codec decode only.

async def _encode_payload_sequence(self, payloads: Sequence[temporalio.api.common.v1.Payload]) -> list[temporalio.api.common.v1.Payload]: (source)
overrides temporalio.converter.DataConverter._encode_payload_sequence

Codec encode only.

async def _external_retrieve_payload_sequence(self, payloads: Sequence[temporalio.api.common.v1.Payload]) -> list[temporalio.api.common.v1.Payload]: (source)
overrides temporalio.converter.DataConverter._external_retrieve_payload_sequence

External storage retrieve only.

async def _external_store_payload_sequence(self, payloads: Sequence[temporalio.api.common.v1.Payload]) -> list[temporalio.api.common.v1.Payload]: (source)
overrides temporalio.converter.DataConverter._external_store_payload_sequence

External storage store, then validate payload limits.

def _get_current_dc(self) -> temporalio.converter.DataConverter: (source)

Undocumented

def _validate_payload_limits(self, payloads: Sequence[temporalio.api.common.v1.Payload]): (source)
overrides temporalio.converter.DataConverter._validate_payload_limits

Undocumented

_ca_context_free_dc: temporalio.converter.DataConverter = (source)

Undocumented

_ca_instance: WorkflowInstance = (source)

Undocumented

_ca_workflow_context: temporalio.converter.WorkflowSerializationContext = (source)

Undocumented

_ca_workflow_context_dc: temporalio.converter.DataConverter = (source)

Undocumented