Commit ed9531ca by rao-abdul-mannan

revert user activity output

parent da41d307
...@@ -39,7 +39,7 @@ class UserActivityTask(OverwriteOutputMixin, WarehouseMixin, EventLogSelectionMi ...@@ -39,7 +39,7 @@ class UserActivityTask(OverwriteOutputMixin, WarehouseMixin, EventLogSelectionMi
""" """
output_root = luigi.Parameter() output_root = None
def mapper(self, line): def mapper(self, line):
value = self.get_event_and_date_string(line) value = self.get_event_and_date_string(line)
...@@ -121,14 +121,13 @@ class UserActivityTask(OverwriteOutputMixin, WarehouseMixin, EventLogSelectionMi ...@@ -121,14 +121,13 @@ class UserActivityTask(OverwriteOutputMixin, WarehouseMixin, EventLogSelectionMi
output_file.write('\n') output_file.write('\n')
def output_path_for_key(self, key): def output_path_for_key(self, key):
return get_target_from_url(self.output_root).path date_string = key
# date_string = key return url_path_join(
# return url_path_join( self.hive_partition_path('user_activity', date_string),
# self.hive_partition_path('user_activity', date_string), 'user_activity_{date}'.format(
# 'user_activity_{date}'.format( date=date_string,
# date=date_string, )
# ) )
# )
def run(self): def run(self):
# Remove the marker file. # Remove the marker file.
......
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