Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
leoschwarz committed Sep 18, 2024
1 parent 6270506 commit 2684413
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ def _dispatch_jobs_dataset_flow(self, definition: WorkunitDefinition, params: di
)
paths = []
for row in dataset_df.iter_rows(named=True):
resource_id = row[self._config.dataset_resource_column]
resource_id = int(row[self._config.dataset_resource_column])
row_params = {name: row[dataset_name] for dataset_name, name in self._config.dataset_param_columns}
paths.append(self.dispatch_job(resource=resources[resource_id], params=params | row_params))
return paths

0 comments on commit 2684413

Please sign in to comment.