modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-05-16 13:56:11 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Move messaging.py to common/messaging.py

Browse Source
This commit is contained in:
mprahl
2020-01-03 16:36:22 -05:00
parent b16cb88bc3
commit 18dd43926c
15 changed files with 12 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
module_build_service/scheduler/consumer.py
View File

@@ -19,13 +19,13 @@ import fedmsg.consumers
import moksha.hub
import sqlalchemy.exc
import module_build_service.messaging
import module_build_service.common.messaging
import module_build_service.monitor as monitor
from module_build_service import models, log, conf
from module_build_service.scheduler.db_session import db_session
from module_build_service.errors import IgnoreMessage
from module_build_service.messaging import default_messaging_backend
from module_build_service.common.messaging import default_messaging_backend
from module_build_service.scheduler import events
from module_build_service.scheduler.handlers import components
from module_build_service.scheduler.handlers import repos
@@ -107,8 +107,8 @@ class MBSConsumer(fedmsg.consumers.FedmsgConsumer):
# Furthermore, extend our initial messages with any that were queued up
# in the test environment before our hub was initialized.
while module_build_service.messaging._initial_messages:
msg = module_build_service.messaging._initial_messages.pop(0)
while module_build_service.common.messaging._initial_messages:
msg = module_build_service.common.messaging._initial_messages.pop(0)
self.incoming.put(msg)
self.sanity_check()

1
module_build_service/scheduler/producer.py
View File

@@ -6,7 +6,6 @@ import operator
from datetime import timedelta, datetime
from sqlalchemy.orm import lazyload, load_only
import module_build_service.messaging
import module_build_service.scheduler
import module_build_service.scheduler.consumer
from module_build_service import celery_app, conf, models, log