Traceback (most recent call last):


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/flask/app.py", line 2292, in wsgi_app

response = self.full_dispatch_request()


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/flask/app.py", line 1815, in full_dispatch_request

rv = self.handle_user_exception(e)


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/flask/app.py", line 1718, in handle_user_exception

reraise(exc_type, exc_value, tb)


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/flask/_compat.py", line 35, in reraise

raise value


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/flask/app.py", line 1813, in full_dispatch_request

rv = self.dispatch_request()


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/flask/app.py", line 1799, in dispatch_request

return self.view_functions[rule.endpoint](**req.view_args)


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/mlflow/server/handlers.py", line 81, in wrapper

return func(*args, **kwargs)


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/mlflow/server/handlers.py", line 288, in _search_runs

response_message.runs.extend([r.to_proto() for r in run_entities])


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/mlflow/server/handlers.py", line 288, in <listcomp>

response_message.runs.extend([r.to_proto() for r in run_entities])


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/mlflow/entities/run.py", line 38, in to_proto

run.info.MergeFrom(self.info.to_proto())


 "/home/ec2-user/anaconda3/lib/python3.7/site-packages/mlflow/entities/run_info.py", line 150, in to_proto

proto.experiment_id = self.experiment_id
TypeError: 0 has type int, but expected one of: bytes, unicode

Traceback (most recent call last):


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

self._prepare_and_execute_task_with_callbacks(context, task)


 "/usr/local/lib/python3.8/site-packages/airflow/models/taskinstance.py", line 1260, in _prepare_and_execute_task_with_callbacks

result = self._execute_task(context, task_copy)


 "/usr/local/lib/python3.8/site-packages/airflow/models/taskinstance.py", line 1300, in _execute_task

result = task_copy.execute(context=context)


 "/home/airflow/nfs/dags/catwalk/monitor_dag_try.py", line 79, in execute

self._handle_error_state(hook, cluster)


 "/usr/local/lib/python3.8/site-packages/airflow/providers/google/cloud/operators/dataproc.py", line 568, in _handle_error_state

gcs_uri = hook.diagnose_cluster(


 "/usr/local/lib/python3.8/site-packages/airflow/providers/google/common/hooks/base_google.py", line 425, in inner_wrapper

return func(self, *args, **kwargs)


 "/usr/local/lib/python3.8/site-packages/airflow/providers/google/cloud/hooks/dataproc.py", line 390, in diagnose_cluster

operation.result()


 "/usr/local/lib/python3.8/site-packages/google/api_core/future/polling.py", line 129, in result

self._blocking_poll(timeout=timeout, **kwargs)


 "/usr/local/lib/python3.8/site-packages/google/api_core/future/polling.py", line 107, in _blocking_poll

retry_(self._done_or_raise)(**kwargs)


 "/usr/local/lib/python3.8/site-packages/google/api_core/retry.py", line 281, in retry_wrapped_func

return retry_target(


 "/usr/local/lib/python3.8/site-packages/google/api_core/retry.py", line 184, in retry_target

return target()


 "/usr/local/lib/python3.8/site-packages/google/api_core/future/polling.py", line 85, in _done_or_raise

if not self.done(**kwargs):


 "/usr/local/lib/python3.8/site-packages/google/api_core/operation.py", line 170, in done

self._refresh_and_update(retry)


 "/usr/local/lib/python3.8/site-packages/google/api_core/operation.py", line 159, in _refresh_and_update

self._set_result_from_operation()


 "/usr/local/lib/python3.8/site-packages/google/api_core/operation.py", line 130, in _set_result_from_operation

response = protobuf_helpers.from_any_pb(


 "/usr/local/lib/python3.8/site-packages/google/api_core/protobuf_helpers.py", line 69, in from_any_pb

raise TypeError(
TypeError: Could not convert Any to Empty
