Commit 95b4b4e1 by Hassan Javeed

.

parent 3495bc44
...@@ -110,7 +110,7 @@ class ActiveUsersPartitionTask(WeeklyIntervalMixin, ActiveUsersDownstreamMixin, ...@@ -110,7 +110,7 @@ class ActiveUsersPartitionTask(WeeklyIntervalMixin, ActiveUsersDownstreamMixin,
class LoadInternalReportingActiveUsersToWarehouse(WarehouseMixin, VerticaCopyTask): class LoadInternalReportingActiveUsersToWarehouse(WarehouseMixin, VerticaCopyTask):
"""Loads the active_users_this_year hive table into Vertica warehouse.""" """Loads the active_users_this_year hive table into Vertica warehouse."""
HIVE_TABLE = 'active_users_this_year' HIVE_TABLE = 'active_users_per_week'
date = luigi.DateParameter() date = luigi.DateParameter()
...@@ -137,7 +137,7 @@ class LoadInternalReportingActiveUsersToWarehouse(WarehouseMixin, VerticaCopyTas ...@@ -137,7 +137,7 @@ class LoadInternalReportingActiveUsersToWarehouse(WarehouseMixin, VerticaCopyTas
@property @property
def table(self): def table(self):
return 'f_active_users_this_year' return 'f_active_users_per_week'
@property @property
def auto_primary_key(self): def auto_primary_key(self):
...@@ -151,7 +151,7 @@ class LoadInternalReportingActiveUsersToWarehouse(WarehouseMixin, VerticaCopyTas ...@@ -151,7 +151,7 @@ class LoadInternalReportingActiveUsersToWarehouse(WarehouseMixin, VerticaCopyTas
@property @property
def columns(self): def columns(self):
return [ return [
('window_start_date', 'DATE'), ('start_date', 'DATE'),
('window_end_date', 'DATE'), ('end_date', 'DATE'),
('username', 'VARCHAR(45) NOT NULL'), ('username', 'VARCHAR(45) NOT NULL'),
] ]
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