We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8ca0bcb commit e8906c4Copy full SHA for e8906c4
python/ray/data/tests/test_streaming_executor.py
@@ -766,9 +766,6 @@ def test_create_topology_metadata():
766
assert len(map_op2.input_dependencies) == 1
767
assert map_op2.input_dependencies[0] == map_op1.id
768
769
- # Cleanup
770
- executor.shutdown()
771
-
772
773
def test_create_topology_metadata_with_sub_stages():
774
"""Test that _dump_dag_structure correctly handles sub-stages."""
@@ -817,9 +814,6 @@ def test_create_topology_metadata_with_sub_stages():
817
814
assert sub_stage2.name == "SubStage2"
818
815
assert sub_stage2.id.endswith("_sub_1")
819
816
820
821
822
823
824
if __name__ == "__main__":
825
import sys
0 commit comments