Skip to content

Commit c8c0d83

Browse files
committed
Fix the amqp connection for WorkflowExecutionHandler to pass the
SSL params. To pass the SSL params, get_connection() should be used instead. Related commit: dd4465a
1 parent 8252ae8 commit c8c0d83

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

CHANGELOG.rst

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,9 @@ Fixed
104104
NOTE: This issue only affected installations using Python 3. (bug fix) #4832 #4834
105105

106106
Reported by @alexku7.
107+
* Fix the amqp connection setup for WorkflowExecutionHandler to pass SSL params. (bug fix) #4845
108+
109+
Contributed by Tatsuma Matsuki (@mtatsuma)
107110

108111
3.1.0 - June 27, 2019
109112
---------------------

st2actions/st2actions/workflows/workflows.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,6 @@
1414

1515
from __future__ import absolute_import
1616

17-
import kombu
18-
1917
from orquesta import statuses
2018

2119
from st2common.constants import action as ac_const
@@ -179,5 +177,5 @@ def handle_action_execution(self, ac_ex_db):
179177

180178

181179
def get_engine():
182-
with kombu.Connection(txpt_utils.get_messaging_urls()) as conn:
180+
with txpt_utils.get_connection() as conn:
183181
return WorkflowExecutionHandler(conn, WORKFLOW_EXECUTION_QUEUES)

0 commit comments

Comments
 (0)