[beam] branch master updated: Remove timers restriction for FnApi runner.

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 2b6bdc1  Remove timers restriction for FnApi runner.
     new 1a888f4  Merge pull request #7558 from robertwb/fn-api-timers
2b6bdc1 is described below

commit 2b6bdc1b2cb2bd02c787ae4fbfb11ebd0403e8d8
Author: Robert Bradshaw <ro...@google.com>
AuthorDate: Wed Jan 16 14:34:33 2019 +0100

    Remove timers restriction for FnApi runner.
---
 sdks/python/apache_beam/runners/direct/direct_runner.py | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/sdks/python/apache_beam/runners/direct/direct_runner.py b/sdks/python/apache_beam/runners/direct/direct_runner.py
index b882eb3..770044c 100644
--- a/sdks/python/apache_beam/runners/direct/direct_runner.py
+++ b/sdks/python/apache_beam/runners/direct/direct_runner.py
@@ -106,9 +106,6 @@ class SwitchingDirectRunner(PipelineRunner):
           # The FnApiRunner does not support execution of SplittableDoFns.
           if DoFnSignature(dofn).is_splittable_dofn():
             self.supported_by_fnapi_runner = False
-          # The FnApiRunner does not support execution of DoFns with timers.
-          if DoFnSignature(dofn).has_timers():
-            self.supported_by_fnapi_runner = False
           # The FnApiRunner does not support execution of CombineFns with
           # deferred side inputs.
           if isinstance(dofn, CombineValuesDoFn):