diff --git a/src/logging.yml b/src/logging.yml index a2bfd9f..df2adf0 100644 --- a/src/logging.yml +++ b/src/logging.yml @@ -17,6 +17,16 @@ handlers: maxBytes: 100000000 backupCount: 30 loggers: + src.operations: + level: DEBUG + handlers: + - console + - file + src.common: + level: DEBUG + handlers: + - console + - file src.server: level: INFO handlers: diff --git a/src/service_aggregator.py b/src/service_aggregator.py index 8ea5b62..b0f144c 100644 --- a/src/service_aggregator.py +++ b/src/service_aggregator.py @@ -240,6 +240,7 @@ async def post_async(host_url, query, guid, params=None): jr = json.loads(content) if await is_end_message(jr): + logger.debug('Received complete message from multistrider') break query = Query.parse_obj(jr) @@ -249,6 +250,7 @@ async def post_async(host_url, query, guid, params=None): #this is a little messy because this is trying to handle multiquery (returns an end message) # and single query (no end message; single query) if num_queries == 1: + logger.debug('Single message returned from strider; continuing') break else: # file not found