Skip to content

Commit 6eba3b5

Browse files
claudevdmClaude
authored andcommitted
fix loop error.
1 parent 4b448b0 commit 6eba3b5

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

sdks/python/apache_beam/runners/interactive/user_pipeline_tracker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ def evict(self, pipeline: beam.Pipeline) -> None:
6868
def clear(self) -> None:
6969
"""Clears the tracker of all user and derived pipelines."""
7070
# Remove all local_tempdir of created pipelines.
71-
for p in self._pid_to_pipelines.values():
71+
for p in list(self._pid_to_pipelines.values()):
7272
shutil.rmtree(p.local_tempdir, ignore_errors=True)
7373

7474
self._user_pipelines.clear()

0 commit comments

Comments
 (0)