@@ -893,12 +893,14 @@ def create_id(self, i):
893893 )
894894
895895 expected = item_serdes or batch_serdes
896- assert mock_serialize .call_args_list [0 ][1 ]["serdes" ] is expected
897- assert mock_serialize .call_args_list [0 ][1 ]["operation_id" ] == "child-0"
898- assert mock_serialize .call_args_list [1 ][1 ]["serdes" ] is expected
899- assert mock_serialize .call_args_list [1 ][1 ]["operation_id" ] == "child-1"
900- assert mock_serialize .call_args_list [2 ][1 ]["serdes" ] is batch_serdes
901- assert mock_serialize .call_args_list [2 ][1 ]["operation_id" ] == "parent"
896+ serialize_calls = {
897+ call .kwargs ["operation_id" ]: call .kwargs
898+ for call in mock_serialize .call_args_list
899+ }
900+ assert set (serialize_calls ) == {"child-0" , "child-1" , "parent" }
901+ assert serialize_calls ["child-0" ]["serdes" ] is expected
902+ assert serialize_calls ["child-1" ]["serdes" ] is expected
903+ assert serialize_calls ["parent" ]["serdes" ] is batch_serdes
902904
903905
904906@pytest .mark .parametrize (
@@ -956,10 +958,13 @@ def create_id(self, i):
956958 )
957959
958960 expected = item_serdes or batch_serdes
959- assert mock_deserialize .call_args_list [0 ][1 ]["serdes" ] is expected
960- assert mock_deserialize .call_args_list [0 ][1 ]["operation_id" ] == "child-0"
961- assert mock_deserialize .call_args_list [1 ][1 ]["serdes" ] is expected
962- assert mock_deserialize .call_args_list [1 ][1 ]["operation_id" ] == "child-1"
961+ deserialize_calls = {
962+ call .kwargs ["operation_id" ]: call .kwargs
963+ for call in mock_deserialize .call_args_list
964+ }
965+ assert set (deserialize_calls ) == {"child-0" , "child-1" }
966+ assert deserialize_calls ["child-0" ]["serdes" ] is expected
967+ assert deserialize_calls ["child-1" ]["serdes" ] is expected
963968
964969
965970def test_map_result_serialization_roundtrip ():
0 commit comments