X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/aa96d9c4c5c9b107867764d91109a35037c521ce..f3cb43d4be379703a965a1cb14cae5f5c855728f:/tools/crunchstat-summary/crunchstat_summary/summarizer.py diff --git a/tools/crunchstat-summary/crunchstat_summary/summarizer.py b/tools/crunchstat-summary/crunchstat_summary/summarizer.py index 890f28c289..463c552c4f 100644 --- a/tools/crunchstat-summary/crunchstat_summary/summarizer.py +++ b/tools/crunchstat-summary/crunchstat_summary/summarizer.py @@ -4,7 +4,6 @@ import arvados import collections -import arvados.util import crunchstat_summary.dygraphs import crunchstat_summary.reader import datetime @@ -106,7 +105,7 @@ class Summarizer(object): self.label, uuid) continue logger.debug('%s: follow %s', self.label, uuid) - child_summarizer = ProcessSummarizer(uuid) + child_summarizer = NewSummarizer(uuid) child_summarizer.stats_max = self.stats_max child_summarizer.task_stats = self.task_stats child_summarizer.tasks = self.tasks @@ -365,7 +364,7 @@ class Summarizer(object): constraint_key, int(used_cores)) - # FIXME: This needs to be updated to account for current nodemanager algorithms + # FIXME: This needs to be updated to account for current a-d-c algorithms def _recommend_ram(self): """Recommend an economical RAM constraint for this job. @@ -537,7 +536,7 @@ class ProcessSummarizer(Summarizer): # Pre-Arvados v1.4 everything is in 'log' # For 1.4+ containers have no logs and container_requests have them in 'log_uuid', not 'log' log_collection = self.process.get('log', self.process.get('log_uuid')) - if log_collection and self.process.get('state') != arvados.util.CR_UNCOMMITTED: + if log_collection and self.process.get('state') != 'Uncommitted': # arvados.util.CR_UNCOMMITTED: try: rdr = crunchstat_summary.reader.CollectionReader(log_collection) except arvados.errors.NotFoundError as e: