Closes #3418
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2a552001 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2a552001 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2a552001 Branch: refs/heads/gearpump-runner Commit: 2a5520018fb25f96b57e52231a8cc0b191abfce0 Parents: 3785b5b 8cab153 Author: Robert Bradshaw <[email protected]> Authored: Thu Jun 22 12:34:27 2017 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Thu Jun 22 12:34:27 2017 -0700 ---------------------------------------------------------------------- .../runners/portability/fn_api_runner.py | 6 ++++- .../apache_beam/runners/worker/sdk_worker.py | 26 +++++++++++++++----- 2 files changed, 25 insertions(+), 7 deletions(-) ----------------------------------------------------------------------
