Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
leoschwarz committed Sep 26, 2024
1 parent 8288d3c commit dc658e1
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -85,10 +85,12 @@ def _dispatch_jobs_resource_flow(self, definition: WorkunitDefinition, params: d
resources = Resource.find_all(ids=definition.execution.resources, client=self._client)
paths = []
for resource in sorted(resources.values()):
if self._config.resource_flow.filter_suffix is not None and not resource["name"].endswith(
if self._config.resource_flow.filter_suffix is not None and not resource["relativepath"].endswith(
self._config.resource_flow.filter_suffix
):
logger.info(f"Skipping resource {resource['name']!r} as it does not match the extension filter.")
logger.info(
f"Skipping resource {resource['relativepath']!r} as it does not match the extension filter."
)
continue
paths.append(self.dispatch_job(resource=resource, params=params))
return paths
Expand Down

0 comments on commit dc658e1

Please sign in to comment.