diff --git a/src/bfabric/experimental/app_interface/dispatch/dispatch_individual_resources.py b/src/bfabric/experimental/app_interface/dispatch/dispatch_individual_resources.py index 5f4091f9..21560c20 100644 --- a/src/bfabric/experimental/app_interface/dispatch/dispatch_individual_resources.py +++ b/src/bfabric/experimental/app_interface/dispatch/dispatch_individual_resources.py @@ -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