From f99d42d42541ef2cf19bc72bfc3e960c5f4289cd Mon Sep 17 00:00:00 2001 From: anujlamoria Date: Sat, 14 Aug 2021 01:37:48 +0530 Subject: [PATCH] Fixed typo in broker.py Signed-off-by: anujlamoria --- augur/routes/broker.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/augur/routes/broker.py b/augur/routes/broker.py index f0ae672033..24c120b610 100644 --- a/augur/routes/broker.py +++ b/augur/routes/broker.py @@ -75,7 +75,7 @@ def task(): for given_component in list(task['given'].keys()): given.append(given_component) model = task['models'][0] - logger.info("Broker recieved a new user task ... checking for compatible workers for given: " + str(given) + " and model(s): " + str(model) + "\n") + logger.info("Broker received a new user task ... checking for compatible workers for given: " + str(given) + " and model(s): " + str(model) + "\n") logger.debug("Broker's list of all workers: {}\n".format(server.broker._getvalue().keys())) @@ -128,7 +128,7 @@ def worker(): and telling the broker to add this worker to the set it maintains """ worker = request.json - logger.info("Recieved HELLO message from worker {} listening on: https://localhost:{}\ + logger.info("Received HELLO message from worker {} listening on: https://localhost:{}\ ".format(worker['id'], worker['id'].split('.')[2])) if worker['id'] not in server.broker: server.broker[worker['id']] = server.manager.dict() @@ -162,7 +162,7 @@ def worker(): def sync_queue(): task = request.json worker = task['worker_id'] - logger.info("Message recieved that worker {} completed task: {}\n".format(worker,task)) + logger.info("Message received that worker {} completed task: {}\n".format(worker,task)) try: models = server.broker[worker]['models'] givens = server.broker[worker]['given'] @@ -202,7 +202,7 @@ def get_status(): @server.app.route('/{}/workers/remove'.format(server.api_version), methods=['POST']) def remove_worker(): worker = request.json - logger.info("Recieved a message to disconnect worker: {}\n".format(worker)) + logger.info("Received a message to disconnect worker: {}\n".format(worker)) server.broker[worker['id']]['status'] = 'Disconnected' return Response(response=worker, status=200, @@ -212,7 +212,7 @@ def remove_worker(): def task_error(): task = request.json worker_id = task['worker_id'] - # logger.error("Recieved a message that {} ran into an error on task: {}\n".format(worker_id, task)) + # logger.error("Received a message that {} ran into an error on task: {}\n".format(worker_id, task)) if worker_id in server.broker: if server.broker[worker_id]['status'] != 'Disconnected': logger.error("{} ran into error while completing task: {}\n".format(worker_id, task)) @@ -221,4 +221,4 @@ def task_error(): logger.error("A previous instance of {} ran into error while completing task: {}\n".format(worker_id, task)) return Response(response=request.json, status=200, - mimetype="application/json") \ No newline at end of file + mimetype="application/json")