diff --git a/workflow/cli/run.py b/workflow/cli/run.py index bbb5f5f..7339c44 100644 --- a/workflow/cli/run.py +++ b/workflow/cli/run.py @@ -1,6 +1,5 @@ """Fetch and process Work using any method compatible with Tasks API.""" - import platform import signal import time @@ -272,9 +271,7 @@ def attempt( # Get work from the workflow backend try: - work = Work.withdraw( - pipeline=bucket, site=site, tags=tags, parent=parent - ) + work = Work.withdraw(pipeline=bucket, site=site, tags=tags, parent=parent) except Exception as error: logger.exception(error) @@ -314,7 +311,7 @@ def attempt( ] if any(work.notify.slack.dict().values()) and work.plots: work.plots = [f"<{product_url}{plot}|{plot}>" for plot in work.plots] - work.update(**kwargs) # type: ignore + work.update() # type: ignore logger.info("work completed: ✅") unset_tag() return status diff --git a/workflow/definitions/work.py b/workflow/definitions/work.py index 0788282..1a85275 100644 --- a/workflow/definitions/work.py +++ b/workflow/definitions/work.py @@ -369,7 +369,7 @@ def post_model_validation(self) -> "Work": Work: The current work object. """ # Validate if the site provided is allowed in the workspace. - config: Dict[str, Any] = read.workspace(self.workspace.as_posix()) + config: Dict[str, Any] = read.workspace(self.workspace) sites: List[str] = config.get("sites", []) if self.site not in sites: error = (