mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-02 04:57:10 +08:00
BUG: Fix short circuit in StateTransform loop.
A missing `continue` statement was causing the short circuit on event type to not have the intended effect of skipping the update portion of the loop.
This commit is contained in:
@@ -144,6 +144,7 @@ class StatefulTransform(object):
|
||||
DATASOURCE_TYPE.TRADE,
|
||||
DATASOURCE_TYPE.CUSTOM)):
|
||||
yield message
|
||||
continue
|
||||
# allow upstream generators to yield None to avoid
|
||||
# blocking.
|
||||
if message is None:
|
||||
|
||||
Reference in New Issue
Block a user