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

SW-720: Add missing handler to ResourceAssigner

parent 53343887
No related branches found
No related tags found
1 merge request!6Import cobalt2 into lofar4
...@@ -57,7 +57,7 @@ class SpecifiedTaskEventMessageHandler(RATaskSpecifiedEventMessageHandler): ...@@ -57,7 +57,7 @@ class SpecifiedTaskEventMessageHandler(RATaskSpecifiedEventMessageHandler):
except Exception as e: except Exception as e:
logger.error(str(e)) logger.error(str(e))
__all__ = ["SpecifiedTaskListener"] __all__ = ["SpecifiedTaskEventMessageHandler"]
def main(): def main():
...@@ -91,8 +91,10 @@ def main(): ...@@ -91,8 +91,10 @@ def main():
with ResourceAssigner(exchange=options.exchange, with ResourceAssigner(exchange=options.exchange,
broker=options.broker, broker=options.broker,
radb_dbcreds=radb_dbcreds): radb_dbcreds=radb_dbcreds) as assigner:
with RATaskSpecifiedBusListener(exchange=options.exchange, with RATaskSpecifiedBusListener(handler_type=SpecifiedTaskEventMessageHandler,
handler_kwargs={"assigner": assigner},
exchange=options.exchange,
broker=options.broker): broker=options.broker):
with ScheduleChecker(exchange=options.exchange, with ScheduleChecker(exchange=options.exchange,
broker=options.broker): broker=options.broker):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment