diff --git a/mara_pipelines/parallel_tasks/files.py b/mara_pipelines/parallel_tasks/files.py index 7a5477b..8dc0f8d 100644 --- a/mara_pipelines/parallel_tasks/files.py +++ b/mara_pipelines/parallel_tasks/files.py @@ -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: