Traceback (most recent call last):


 "/usr/local/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 984, in _run_raw_task

result = task_copy.execute(context=context)


 "/usr/local/lib/python3.7/site-packages/airflow/operators/python_operator.py", line 113, in execute

return_value = self.execute_callable()


 "/usr/local/lib/python3.7/site-packages/airflow/operators/python_operator.py", line 118, in execute_callable

return self.python_callable(*self.op_args, **self.op_kwargs)


 "/usr/local/airflow/dags/test_dag_2.py", line 44, in run_this_func

print("Remotely received value of {} for key=message".format(context["dag_run"].conf["message"]))
TypeError: 'NoneType' object is not subscriptable

Traceback (most recent call last):


 "run_anomaly.py", line 151, in <module>

runModel(GYM_NAME, plot=plot)


 "run_anomaly.py", line 141, in runModel

runIoThroughNupic(inputData, model, gymName, plot)


 "run_anomaly.py", line 122, in runIoThroughNupic

output.write(timestamp, consumption, prediction, anomalyScore)


 "/root/nupic/swarm/nupic_anomaly_output.py", line 93, in write

value, anomalyScore, timestamp


 "/root/anaconda2/lib/python2.7/site-packages/nupic/algorithms/anomaly_likelihood.py", line 386, in anomalyProbability

skipRecords=numSkipRecords)


 "/root/anaconda2/lib/python2.7/site-packages/nupic/algorithms/anomaly_likelihood.py", line 460, in estimateAnomalyLikelihoods

verbosity = verbosity)


 "/root/anaconda2/lib/python2.7/site-packages/nupic/algorithms/anomaly_likelihood.py", line 672, in _anomalyScoreMovingAverage

MovingAverage.compute(historicalValues, total, record[2], windowSize)


 "/root/anaconda2/lib/python2.7/site-packages/nupic/utils.py", line 81, in compute

total += newVal
TypeError: unsupported operand type(s) for +=: 'float' and 'NoneType'
