From c0a0f868e96955c7bff0bc510386e32f27d4abb4 Mon Sep 17 00:00:00 2001 From: Claude Date: Tue, 10 Mar 2026 09:22:31 -0400 Subject: [PATCH] fix loop error. --- .../apache_beam/runners/interactive/user_pipeline_tracker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/interactive/user_pipeline_tracker.py b/sdks/python/apache_beam/runners/interactive/user_pipeline_tracker.py index 53ee54ac8a35..f49fe888fce2 100644 --- a/sdks/python/apache_beam/runners/interactive/user_pipeline_tracker.py +++ b/sdks/python/apache_beam/runners/interactive/user_pipeline_tracker.py @@ -68,7 +68,7 @@ def evict(self, pipeline: beam.Pipeline) -> None: def clear(self) -> None: """Clears the tracker of all user and derived pipelines.""" # Remove all local_tempdir of created pipelines. - for p in self._pid_to_pipelines.values(): + for p in list(self._pid_to_pipelines.values()): shutil.rmtree(p.local_tempdir, ignore_errors=True) self._user_pipelines.clear()