2.4.3

ERROR:CacheStore:{'type': 'error', 'message': "DAG Parsing failed: 'NoneType' object has no attribute 'flowspec'", 'id': 'DAGParsingFailed', 'traceback': 'Traceback (most recent call last):\n  File "/usr/lib/python3.7/runpy.py", line 193, in _run_module_as_main\n    "__main__", mod_spec)\n  File "/usr/lib/python3.7/runpy.py", line 85, in _run_code\n    exec(code, run_globals)\n  File "/root/services/ui_backend_service/data/cache/client/cache_server.py", line 302, in <module>\n    cli(auto_envvar_prefix=\'MFCACHE\')\n  File "/opt/latest/lib/python3.7/site-packages/click/core.py", line 1128, in __call__\n    return self.main(*args, **kwargs)\n  File "/opt/latest/lib/python3.7/site-packages/click/core.py", line 1053, in main\n    rv = self.invoke(ctx)\n  File "/opt/latest/lib/python3.7/site-packages/click/core.py", line 1395, in invoke\n    return ctx.invoke(self.callback, **ctx.params)\n  File "/opt/latest/lib/python3.7/site-packages/click/core.py", line 754, in invoke\n    return __callback(*args, **kwargs)\n  File "/root/services/ui_backend_service/data/cache/client/cache_server.py", line 298, in cli\n    Scheduler(store, max_actions).loop()\n  File "/root/services/ui_backend_service/data/cache/client/cache_server.py", line 199, in __init__\n    maxtasksperchild=512,  # Recycle each worker once 512 tasks have been completed\n  File "/usr/lib/python3.7/multiprocessing/context.py", line 119, in Pool\n    context=self.get_context())\n  File "/usr/lib/python3.7/multiprocessing/pool.py", line 176, in __init__\n    self._repopulate_pool()\n  File "/usr/lib/python3.7/multiprocessing/pool.py", line 241, in _repopulate_pool\n    w.start()\n  File "/usr/lib/python3.7/multiprocessing/process.py", line 112, in start\n    self._popen = self._Popen(self)\n  File "/usr/lib/python3.7/multiprocessing/context.py", line 277, in _Popen\n    return Popen(process_obj)\n  File "/usr/lib/python3.7/multiprocessing/popen_fork.py", line 20, in __init__\n    self._launch(process_obj)\n  File "/usr/lib/python3.7/multiprocessing/popen_fork.py", line 74, in _launch\n    code = process_obj._bootstrap()\n  File "/usr/lib/python3.7/multiprocessing/process.py", line 297, in _bootstrap\n    self.run()\n  File "/usr/lib/python3.7/multiprocessing/process.py", line 99, in run\n    self._target(*self._args, **self._kwargs)\n  File "/usr/lib/python3.7/multiprocessing/pool.py", line 121, in worker\n    result = (True, func(*args, **kwds))\n  File "/root/services/ui_backend_service/data/cache/client/cache_worker.py", line 29, in execute_action\n    execute(tempdir, action_cls, request)\n  File "/root/services/ui_backend_service/data/cache/client/cache_worker.py", line 56, in execute\n    invalidate_cache=req.get(\'invalidate_cache\', False))\n  File "/root/services/ui_backend_service/data/cache/generate_dag_action.py", line 97, in execute\n    results[result_key] = json.dumps(dag)\n  File "/usr/lib/python3.7/contextlib.py", line 130, in __exit__\n    self.gen.throw(type, value, traceback)\n  File "/root/services/ui_backend_service/data/cache/utils.py", line 130, in streamed_errors\n    get_traceback_str()\n  File "/root/services/ui_backend_service/data/cache/utils.py", line 124, in streamed_errors\n    yield\n  File "/root/services/ui_backend_service/data/cache/generate_dag_action.py", line 95, in execute\n    dag = generate_dag(run)\n  File "/root/services/ui_backend_service/data/cache/generate_dag_action.py", line 123, in generate_dag\n    raise DAGParsingFailed(f"DAG Parsing failed: {str(ex)}")\n\nservices.ui_backend_service.data.cache.utils.DAGParsingFailed: DAG Parsing failed: \'NoneType\' object has no attribute \'flowspec\'\n', 'key': None}

@cards