This commit is contained in:
Dana Van Aken 2020-04-17 17:52:54 -04:00
parent ca63f91f55
commit c9370b76a3
1 changed files with 4 additions and 3 deletions

View File

@ -94,11 +94,12 @@ def run_background_tasks():
knob_data['data'].shape) knob_data['data'].shape)
LOG.info("Done aggregating data for workload %s.", workload_name) LOG.info("Done aggregating data for workload %s.", workload_name)
num_valid_results = knob_data['data'].shape[0] num_valid_results = knob_data['data'].shape[0] # pylint: disable=unsubscriptable-object
if num_valid_results < MIN_WORKLOAD_RESULTS_COUNT: if num_valid_results < MIN_WORKLOAD_RESULTS_COUNT:
# Check that there are enough valid results in the workload # Check that there are enough valid results in the workload
LOG.info("Not enough valid results in workload %s (# valid results: %s, # required: %s).", LOG.info("Not enough valid results in workload %s (# valid results: "
workload_name, num_valid_results, MIN_WORKLOAD_RESULTS_COUNT) "%s, # required: %s).", workload_name, num_valid_results,
MIN_WORKLOAD_RESULTS_COUNT)
workload.status = WorkloadStatusType.PROCESSED workload.status = WorkloadStatusType.PROCESSED
workload.save() workload.save()
continue continue