From 81aac15ec60427a9c3526abbd08dd6a0b2cafebd Mon Sep 17 00:00:00 2001 From: Ivan Vazhenin Date: Mon, 4 Dec 2023 20:01:46 +0300 Subject: [PATCH] Add ws rabbit config --- config.py | 8 ++++++++ main.py | 4 ++++ 2 files changed, 12 insertions(+) diff --git a/config.py b/config.py index b621088..6c080df 100644 --- a/config.py +++ b/config.py @@ -21,6 +21,14 @@ class Config: rabbit_conn: str = 'amqp://user:password@10.10.8.83:31005/%2f' rabbit_queue: str = 'ipd' + ws_rabbit_params: dict = { + 'host': '10.10.8.83', + 'port': 31005, + 'exchange': 'ipd', + 'user': 'user', + 'password': 'password', + } + s3_endpoint: str = 'http://10.10.8.83:31006' s3_key_id: str = 's57' s3_access_key: str = 'd9MMinLF3U8TLSj' diff --git a/main.py b/main.py index 242ab03..d721f19 100644 --- a/main.py +++ b/main.py @@ -577,6 +577,10 @@ def apply_commits(params, files, url): con = OOConnectionParams(scheme, Config.oodb_host, Config.oodb_port, Config.oodb_dbname, Config.oodb_username, Config.oodb_passwd, scheme) ws = OODBWorkspace.ws(scheme) + if Config.ws_rabbit_params and not ws.hasProducer(): + ws.setProducer(Config.ws_rabbit_params['host'], Config.ws_rabbit_params['port'], + Config.ws_rabbit_params['exchange'], Config.ws_rabbit_params['user'], + Config.ws_rabbit_params['password']) ws.setCurrentUser(bnd) if branch: logging.warning(branch)