Test

Author: dandavison

tests/test_serialization_context.py

@@ -62,16 +62,25 @@ def with_context(
         return converter
 
     def to_payload(self, value: Any) -> Optional[Payload]:
+        print(
+            f"🌈 SerializationContextTestEncodingPayloadConverter.to_payload({value})"
+        )
         assert isinstance(value, TraceData)
         assert isinstance(self.context, WorkflowSerializationContext)
         value.items.append(
             TraceItem(
                 context_type="workflow", method="to_payload", context=self.context
             )
         )
-        return None
+        payload = JSONPlainPayloadConverter().to_payload(value)
+        assert payload
+        payload.metadata["encoding"] = self.encoding.encode()
+        return payload
 
     def from_payload(self, payload: Payload, type_hint: Optional[Type] = None) -> Any:
+        print(
+            f"🌈 SerializationContextTestEncodingPayloadConverter.from_payload({payload}, {type_hint})"
+        )
         value = JSONPlainPayloadConverter().from_payload(payload, type_hint)
         assert isinstance(value, TraceData)
         assert isinstance(self.context, WorkflowSerializationContext)
@@ -102,6 +111,7 @@ def __init__(self):
 async def test_workflow_payload_conversion_can_be_given_access_to_serialization_context(
     client: Client,
 ):
+    print()
     workflow_id = str(uuid.uuid4())
     task_queue = str(uuid.uuid4())