@@ -103,17 +103,11 @@ def encoding(self) -> str:
103103 def with_context (
104104 self , context : Optional [SerializationContext ]
105105 ) -> SerializationContextTestEncodingPayloadConverter :
106- print (
107- f"🌈 SerializationContextTestEncodingPayloadConverter.with_context({ context } )"
108- )
109106 converter = SerializationContextTestEncodingPayloadConverter ()
110107 converter .context = context
111108 return converter
112109
113110 def to_payload (self , value : Any ) -> Optional [Payload ]:
114- print (
115- f"🌈 SerializationContextTestEncodingPayloadConverter.to_payload({ value } )"
116- )
117111 assert isinstance (value , TraceData )
118112 assert isinstance (self .context , WorkflowSerializationContext )
119113 value .items .append (
@@ -131,9 +125,6 @@ def to_payload(self, value: Any) -> Optional[Payload]:
131125 return payload
132126
133127 def from_payload (self , payload : Payload , type_hint : Optional [Type ] = None ) -> Any :
134- print (
135- f"🌈 SerializationContextTestEncodingPayloadConverter.from_payload({ payload } , { type_hint } )"
136- )
137128 value = JSONPlainPayloadConverter ().from_payload (payload , type_hint )
138129 assert isinstance (value , TraceData )
139130 assert isinstance (self .context , WorkflowSerializationContext )
@@ -168,7 +159,6 @@ def __init__(self):
168159async def test_workflow_payload_conversion_can_be_given_access_to_serialization_context (
169160 client : Client ,
170161):
171- print ()
172162 workflow_id = str (uuid .uuid4 ())
173163 task_queue = str (uuid .uuid4 ())
174164
0 commit comments