pabloem commented on a change in pull request #11166: [BEAM-7923] Emit info
when capture control options are configured.
URL: https://github.com/apache/beam/pull/11166#discussion_r395232854
##########
File path: sdks/python/apache_beam/runners/interactive/interactive_beam.py
##########
@@ -92,7 +117,17 @@ def capture_duration(self, value):
interactive_beam.collect(some_pcoll)
"""
assert value.total_seconds() > 0, 'Duration must be a positive value.'
- self.capture_control._capture_duration = value
+ if self.capture_control._capture_duration.total_seconds(
+ ) != value.total_seconds():
+ _ = ie.current_env()
+ _LOGGER.info(
+ 'You have changed capture duration from %s seconds to %s seconds. '
+ 'To allow new data being captured for the updated duration the next '
Review comment:
```suggestion
'To allow new data to be captured for the updated duration, the
next '
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
