Commit b533cd66 by Toby Lawrence

proper partition for events

parent f256e39e
...@@ -1189,7 +1189,7 @@ class LoadDailyEventRecordToVertica(EventRecordDownstreamMixin, VerticaCopyTask) ...@@ -1189,7 +1189,7 @@ class LoadDailyEventRecordToVertica(EventRecordDownstreamMixin, VerticaCopyTask)
@property @property
def table_partition_key(self): def table_partition_key(self):
return 'date' return 'SUBSTR(date, 0, 8)'
class LoadEventRecordIntervalToVertica(EventRecordDownstreamMixin, VerticaCopyTaskMixin, luigi.WrapperTask): class LoadEventRecordIntervalToVertica(EventRecordDownstreamMixin, VerticaCopyTaskMixin, luigi.WrapperTask):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment