Skip to content

Commit 837ba2f

Browse files
committed
Add missing base case
1 parent e28e463 commit 837ba2f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

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

149+
runner = BundleBasedDirectRunner()
150+
149151
# Check whether all transforms used in the pipeline are supported by the
150152
# FnApiRunner, and the pipeline was not meant to be run as streaming.
151153
if _PrismRunnerSupportVisitor().accept(pipeline):

0 commit comments

Comments
 (0)