diff --git a/shared/channels/src/channels/amqp_helpers.py b/shared/channels/src/channels/amqp_helpers.py index e2a08c79182dba5682c60b32cf4e5e3fd9692735..0f31b5c53ce3e408e4e258e06c5d230ff23c1231 100644 --- a/shared/channels/src/channels/amqp_helpers.py +++ b/shared/channels/src/channels/amqp_helpers.py @@ -9,6 +9,8 @@ from workspaces.json import WorkflowEventSchema from workspaces.schema import WorkflowEvent T = TypeVar('T', contravariant=True) +# Global connection; remains open until manually closed (I imagine by some sort of cleanup process) +# FIXME: Does not currently automatically close itself CONN = None