Dear Beam users,

In the python SDK I tried using the PeriodicImpulse but seems like there is
an internal bug. In the periodicsequence.py on line 42 there is a division
where a type Duration is being divided, but no division operation is
defined. What am I missing? Is there a workaround to this? Here is the
error message that lead to this "discovery":
File
"/home/user/.virtualenvs/dflowenv/lib/python3.8/site-packages/apache_beam/transforms/periodicsequence.py",
line 42, in initial_restriction
   total_outputs = math.ceil((end - start) / interval)
TypeError: unsupported operand type(s) for /: 'Duration' and 'Duration'
[while running 'read/periodic_impulse/GenSequence/PairWithRestriction']

Reply via email to