This is an automated email from the ASF dual-hosted git repository. goenka 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 4670398 [BEAM-7642] Fix python sdk AfterProcessingTime unit discrepancy new de1cfd1 Merge pull request #9397 from y1chi/BEAM-7642 4670398 is described below commit 4670398811572b86f08670a0248544b5cc6b4745 Author: Yichi Zhang <zyi...@google.com> AuthorDate: Wed Aug 21 18:16:38 2019 -0700 [BEAM-7642] Fix python sdk AfterProcessingTime unit discrepancy --- sdks/python/apache_beam/transforms/trigger.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/transforms/trigger.py b/sdks/python/apache_beam/transforms/trigger.py index dbda3cc..e1db856 100644 --- a/sdks/python/apache_beam/transforms/trigger.py +++ b/sdks/python/apache_beam/transforms/trigger.py @@ -337,12 +337,12 @@ class AfterProcessingTime(TriggerFn): proto.after_processing_time .timestamp_transforms[0] .delay - .delay_millis)) + .delay_millis) // 1000) def to_runner_api(self, context): delay_proto = beam_runner_api_pb2.TimestampTransform( delay=beam_runner_api_pb2.TimestampTransform.Delay( - delay_millis=self.delay)) + delay_millis=self.delay * 1000)) return beam_runner_api_pb2.Trigger( after_processing_time=beam_runner_api_pb2.Trigger.AfterProcessingTime( timestamp_transforms=[delay_proto]))