Skip to content
Snippets Groups Projects
Commit 6c345b0e authored by Auke Klazema's avatar Auke Klazema
Browse files

SW-720: Add missing handler to ResourceAssigner (merge from trunk)

parent 035054e2
No related branches found
No related tags found
1 merge request!4Lofar release 4 0 minor fixes
......@@ -57,7 +57,7 @@ class SpecifiedTaskEventMessageHandler(RATaskSpecifiedEventMessageHandler):
except Exception as e:
logger.error(str(e))
__all__ = ["SpecifiedTaskListener"]
__all__ = ["SpecifiedTaskEventMessageHandler"]
def main():
......@@ -91,8 +91,10 @@ def main():
with ResourceAssigner(exchange=options.exchange,
broker=options.broker,
radb_dbcreds=radb_dbcreds):
with RATaskSpecifiedBusListener(exchange=options.exchange,
radb_dbcreds=radb_dbcreds) as assigner:
with RATaskSpecifiedBusListener(handler_type=SpecifiedTaskEventMessageHandler,
handler_kwargs={"assigner": assigner},
exchange=options.exchange,
broker=options.broker):
with ScheduleChecker(exchange=options.exchange,
broker=options.broker):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment