Skip to content

Commit

Permalink
Removed print statements, and added fail when debug logs aren't empty
Browse files Browse the repository at this point in the history
  • Loading branch information
jaredoconnell committed Sep 19, 2023
1 parent 3f467d4 commit ced8b2b
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions src/arcaflow_plugin_sdk/test_atp.py
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,6 @@ def signal_test_step(self, params: StepTestInput) -> Tuple[str, Union[SignalTest
description="Records the value, and optionally ends the step.",
)
def signal_test_signal_handler(self, signal_input: SignalTestInput):
print("Got signal")
self.signal_values.append(signal_input.value)
if signal_input.final:
self.exit_event.set()
Expand Down Expand Up @@ -162,22 +161,18 @@ def test_full_workflow_with_signals(self):
)

client.start_work("signal_test_step", {"wait_time_seconds": "5"})
print("Start work sent")
client.send_signal("signal_test_step", "record_value",
{"final": "false", "value": "1"},
)
print("Signal sent")
client.send_signal("signal_test_step", "record_value",
{"final": "false", "value": "2"},
)
print("Signal sent")
client.send_signal("signal_test_step", "record_value",
{"final": "true", "value": "3"},
)
print("Signal sent. Reading results...")
output_id, output_data, debug_logs = client.read_results()
client.send_client_done()
print(f"debug_logs:\n{debug_logs}\nend of debug logs")
self.assertEqual(debug_logs, "")
self.assertEqual(output_id, "success")
self.assertListEqual(output_data["signals_received"], [1, 2, 3])
finally:
Expand Down

0 comments on commit ced8b2b

Please sign in to comment.