mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-01 05:39:53 +08:00
minor protocol change
This commit is contained in:
@@ -105,7 +105,8 @@ class StatefulTransform(object):
|
||||
# FORWARDER flag means we want to keep all original
|
||||
# values, plus append tnfm_id and tnfm_value. Used for
|
||||
# preserving the original event fields when our output
|
||||
# will be fed into a merge.
|
||||
# will be fed into a merge. Currently only Passthrough
|
||||
# uses this flag.
|
||||
if self.forward_all:
|
||||
out_message = message_copy
|
||||
out_message.tnfm_id = self.namestring
|
||||
|
||||
+1
-1
@@ -658,7 +658,7 @@ def tuple_to_date(date_tuple):
|
||||
# message with its type.
|
||||
DATASOURCE_TYPE = Enum(
|
||||
'AS_TRADED_EQUITY',
|
||||
'MERGE',
|
||||
'MERGER',
|
||||
'SPLIT',
|
||||
'DIVIDEND',
|
||||
'TRADE',
|
||||
|
||||
Reference in New Issue
Block a user