diff --git a/core/functionality.py b/core/functionality.py index e264866..e784b4b 100644 --- a/core/functionality.py +++ b/core/functionality.py @@ -51,17 +51,11 @@ def wait(inputs:list[VALID_CHANNELS])->list[VALID_CHANNELS]: all_connections = [i for i in inputs if type(i) is Connection] \ + [i for i in inputs if type(i) is PipeConnection] \ + [i._reader for i in inputs if type(i) is Queue] - print(inputs) - for i in inputs: - print(type(i)) - print(all_connections) ready = multi_wait(all_connections) - print(ready) ready_inputs = [i for i in inputs if \ (type(i) is Connection and i in ready) \ or (type(i) is PipeConnection and i in ready) \ or (type(i) is Queue and i._reader in ready)] - print(ready_inputs) return ready_inputs def _get_file_sha256(file_path):