Skip to content

Commit e28e463

Browse files
committed
Clean up fallback code
1 parent 99837ca commit e28e463

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

sdks/python/apache_beam/runners/direct/direct_runner.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,6 @@ def visit_transform(self, applied_ptransform):
146146
if timer.time_domain == TimeDomain.REAL_TIME:
147147
self.supported_by_prism_runner = False
148148

149-
tryingPrism = False
150149
# Check whether all transforms used in the pipeline are supported by the
151150
# FnApiRunner, and the pipeline was not meant to be run as streaming.
152151
if _PrismRunnerSupportVisitor().accept(pipeline):

0 commit comments

Comments
 (0)