Skip to content

Commit

Permalink
fix _ParallelRead since merge of mara_storage #55
Browse files Browse the repository at this point in the history
  • Loading branch information
leo-schick committed Sep 19, 2023
1 parent e178adb commit e4c14bb
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion mara_pipelines/parallel_tasks/files.py
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ def update_file_dependencies():
def parallel_commands(self, file_name: str) -> List[pipelines.Command]:
return [self.read_command(file_name)] + (
[python.RunFunction(function=lambda: _processed_files.track_processed_file(
self.path(), file_name, self._storage_client.path_last_modification_timestamp(file_name)))]
self.path(), file_name, self._storage_client.last_modification_timestamp(file_name)))]
if self.read_mode != ReadMode.ALL else [])

def read_command(self, file_name: str) -> pipelines.Command:
Expand Down

0 comments on commit e4c14bb

Please sign in to comment.