From ff341682c507b0181e7a24c297d1ab1ef7ffe1de Mon Sep 17 00:00:00 2001 From: Jared O'Connell Date: Fri, 15 Sep 2023 17:55:15 -0400 Subject: [PATCH] Re-enabled exit event, and added missing cancelled_early output --- arcaflow_plugin_wait/arcaflow_plugin_wait.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/arcaflow_plugin_wait/arcaflow_plugin_wait.py b/arcaflow_plugin_wait/arcaflow_plugin_wait.py index c7588ec..906a1aa 100644 --- a/arcaflow_plugin_wait/arcaflow_plugin_wait.py +++ b/arcaflow_plugin_wait/arcaflow_plugin_wait.py @@ -50,17 +50,17 @@ class WaitStep: description, icon=predefined_schemas.cancel_signal_schema.display.icon, ) - def cancel_step(self, input: predefined_schemas.cancelInput): + def cancel_step(self, _input: predefined_schemas.cancelInput): # First, let it know that this is the reason it's exiting. self.finished_early = True # Now signal to exit. - #self.exit.set() + self.exit.set() @plugin.step_with_signals( id="wait", name="Wait", description="Waits for the given amount of time", - outputs={"success": SuccessOutput, "error": ErrorOutput}, + outputs={"success": SuccessOutput, "error": ErrorOutput, "cancelled_early": ErrorOutput}, signal_handler_method_names=["cancel_step"], signal_emitters=[], step_object_constructor=lambda: WaitStep(),