We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b763c71 commit 796865eCopy full SHA for 796865e
st2actions/st2actions/workflows/workflows.py
@@ -14,8 +14,6 @@
14
15
from __future__ import absolute_import
16
17
-import kombu
18
-
19
from orquesta import statuses
20
21
from st2common.constants import action as ac_const
@@ -179,5 +177,5 @@ def handle_action_execution(self, ac_ex_db):
179
177
180
178
181
def get_engine():
182
- with kombu.Connection(txpt_utils.get_messaging_urls()) as conn:
+ with txpt_utils.get_connection() as conn:
183
return WorkflowExecutionHandler(conn, WORKFLOW_EXECUTION_QUEUES)
0 commit comments