This closes #1174
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c03e3e92 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c03e3e92 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c03e3e92 Branch: refs/heads/python-sdk Commit: c03e3e926c38846ad02cf6d7bf857499927d54bd Parents: 79bb2c2 7239ebb Author: Kenneth Knowles <k...@google.com> Authored: Tue Oct 25 10:46:43 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Oct 25 10:46:43 2016 -0700 ---------------------------------------------------------------------- .../runners/direct/DoFnLifecycleManager.java | 56 +++++++++------ .../direct/DoFnLifecycleManagerTest.java | 74 ++++++++++++++++++-- 2 files changed, 104 insertions(+), 26 deletions(-) ----------------------------------------------------------------------