diff --git a/src/analytics/server.py b/src/analytics/server.py index 94d4e3c6..887d10c6 100644 --- a/src/analytics/server.py +++ b/src/analytics/server.py @@ -68,7 +68,7 @@ class AnalyticsServer: # Make sure everyone sent results and there were no exceptions (e.g. concurrency) failed = not isinstance(results, dict) - failed = failed or not any( + failed = failed or any( result is None or isinstance(result, Exception) for result in results.values() ) if failed: @@ -80,6 +80,8 @@ class AnalyticsServer: ) return False + logger.debug(f"Creating snapshot from: {results}") + # Now we have a dictionary of shard snapshots, aggregate, pull in remaining data, and store. # TODO Possibly move this out into snapshots.py? aggregate = {field: 0 for field in ShardSnapshot._fields}