By type
2021-06-07 14:00:59,611||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074459.609911801","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:00:59,623||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 220 exited with status 2
2021-06-07 14:01:00,238||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074460.237493665","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:01:00,244||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 224 exited with status 2
2021-06-07 14:03:07,833||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074587.832377275","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:03:07,833||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074587.832411153","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:03:07,843||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 516 exited with status 2
2021-06-07 14:03:07,848||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 520 exited with status 2
Process Process-6:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074601.832904254","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:03:21,841||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 982 exited with status 1
2021-06-07 14:03:21,859||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074601.857784251","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:03:21,866||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 981 exited with status 2
2021-06-07 14:03:44,309||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074624.308291056","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:03:44,316||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1007 exited with status 2
2021-06-07 14:03:44,391||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074624.390361988","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:03:44,397||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1012 exited with status 2
2021-06-07 14:04:01,261||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074641.260645928","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:04:01,268||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1110 exited with status 2
2021-06-07 14:04:11,652||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074651.650517518","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:04:11,661||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1154 exited with status 2
2021-06-07 14:04:25,030||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074665.029453151","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:04:25,039||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1105 exited with status 2
2021-06-07 14:04:26,719||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074666.717756138","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:04:26,726||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1179 exited with status 2
Process Process-13:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074673.112542987","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:04:33,121||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1212 exited with status 1
2021-06-07 14:04:40,114||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074680.113350764","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:04:40,122||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1217 exited with status 2
Process Process-15:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074680.260969958","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:04:40,268||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1226 exited with status 1
Process Process-17:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074687.407710779","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:04:47,418||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1246 exited with status 1
2021-06-07 14:08:37,041||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074917.039951904","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:08:37,051||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1242 exited with status 2
2021-06-07 14:08:44,891||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623074924.890588787","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:08:44,899||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 1266 exited with status 2
2021-06-07 14:11:48,468||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075108.466843232","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:11:48,478||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 3047 exited with status 2
2021-06-07 14:11:48,547||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075108.546351284","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:11:48,556||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 3031 exited with status 2
2021-06-07 14:12:19,099||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075139.098136237","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:12:19,107||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 4411 exited with status 2
2021-06-07 14:14:06,358||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075246.357542233","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:14:06,367||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 4556 exited with status 2
2021-06-07 14:15:05,485||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075305.484412677","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:15:05,495||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 4416 exited with status 2
2021-06-07 14:15:10,233||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075310.232620098","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:15:10,246||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 5239 exited with status 2
2021-06-07 14:15:31,351||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075331.350568678","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:15:31,361||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 5612 exited with status 2
2021-06-07 14:16:07,044||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075367.043899989","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:16:07,055||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 5605 exited with status 2
2021-06-07 14:18:10,499||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075490.498505053","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:18:10,499||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075490.498505007","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:18:10,510||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 5903 exited with status 2
2021-06-07 14:18:10,515||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 5670 exited with status 2
Process Process-30:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075498.805351083","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:18:18,813||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6378 exited with status 1
2021-06-07 14:18:24,500||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075504.499230125","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:18:24,507||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6377 exited with status 2
2021-06-07 14:18:57,514||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075537.513179783","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:18:57,529||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6412 exited with status 2
2021-06-07 14:19:03,647||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075543.646206549","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:19:03,654||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6401 exited with status 2
2021-06-07 14:19:05,556||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075545.554774410","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:19:05,563||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6516 exited with status 2
2021-06-07 14:19:46,109||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075586.108322004","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:19:46,115||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6524 exited with status 2
2021-06-07 14:19:59,580||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075599.578934204","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:19:59,588||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6544 exited with status 2
2021-06-07 14:25:14,330||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075914.329428538","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:25:14,339||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6658 exited with status 2
2021-06-07 14:25:21,331||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075921.330033004","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:25:21,338||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 6686 exited with status 2
Process Process-38:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075928.330121150","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:25:28,340||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 9051 exited with status 1
2021-06-07 14:25:35,331||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075935.330559406","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:25:35,338||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 9062 exited with status 2
Process Process-40:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623075935.825623823","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:25:35,833||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 9081 exited with status 1
2021-06-07 14:27:33,956||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076053.955270796","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:27:33,966||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 9098 exited with status 2
2021-06-07 14:28:47,026||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076127.024609435","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:28:47,037||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 9920 exited with status 2
2021-06-07 14:28:47,177||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076127.172747758","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:28:47,184||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 9102 exited with status 2
Process Process-45:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076134.205528850","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:28:54,214||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10387 exited with status 1
2021-06-07 14:29:53,970||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076193.968702465","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:29:53,987||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10383 exited with status 2
2021-06-07 14:29:54,054||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076194.053070808","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:29:54,061||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10402 exited with status 2
2021-06-07 14:30:41,348||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076241.347229717","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:30:41,357||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10661 exited with status 2
2021-06-07 14:30:45,574||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076245.572974067","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:30:45,583||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10657 exited with status 2
Process Process-49:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076248.379332247","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:30:48,390||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10812 exited with status 1
2021-06-07 14:30:55,380||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076255.379549003","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:30:55,387||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10827 exited with status 2
Process Process-51:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076259.572467523","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:30:59,584||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10835 exited with status 1
2021-06-07 14:31:03,408||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076263.406790479","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:31:03,415||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10852 exited with status 2
2021-06-07 14:35:55,873||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076555.872492196","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:35:55,883||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10859 exited with status 2
2021-06-07 14:35:57,268||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076557.267823960","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:35:57,276||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 10865 exited with status 2
Process Process-55:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076562.932500519","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:36:02,943||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 13228 exited with status 1
2021-06-07 14:41:17,555||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076877.554198021","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:41:17,564||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 13241 exited with status 2
2021-06-07 14:41:37,677||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076897.669020899","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:41:37,685||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 15355 exited with status 2
2021-06-07 14:41:42,133||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076902.132435289","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:41:42,142||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 13233 exited with status 2
Process Process-59:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 834, in transaction
txn_response = self.kvstub.Txn(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076912.165216126","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 444, in put_if_not_exists
status, _ = self.transaction(
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:41:52,174||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 15395 exited with status 1
2021-06-07 14:42:17,602||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076937.600995320","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:42:17,606||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623076937.605703900","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:42:17,610||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 15400 exited with status 2
2021-06-07 14:42:17,614||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 15419 exited with status 2
2021-06-07 14:51:55,366||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623077515.365334029","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:51:55,376||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 15521 exited with status 2
2021-06-07 14:51:55,447||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623077515.446792794","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 14:51:55,455||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 15520 exited with status 2
2021-06-07 14:59:20,141||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623077960.139898260","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 14:59:20,150||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 19560 exited with status 2
2021-06-07 15:03:51,912||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078231.911249747","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:03:51,917||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078231.916354966","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:03:51,921||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 19565 exited with status 2
2021-06-07 15:03:51,925||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 21966 exited with status 2
Process Process-68:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078238.944716245","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:03:58,955||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 23491 exited with status 1
2021-06-07 15:06:19,191||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078379.189804105","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:06:19,200||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 23514 exited with status 2
2021-06-07 15:06:27,340||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078387.339088029","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:06:27,348||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 23490 exited with status 2
Process Process-70:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 834, in transaction
txn_response = self.kvstub.Txn(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078389.864073252","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 444, in put_if_not_exists
status, _ = self.transaction(
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:06:29,874||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 24323 exited with status 1
2021-06-07 15:10:19,795||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078619.794302362","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:10:19,804||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 24348 exited with status 2
2021-06-07 15:12:00,497||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078720.495765736","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:12:00,508||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 25733 exited with status 2
2021-06-07 15:12:14,251||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078734.250738165","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:12:14,259||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 24341 exited with status 2
2021-06-07 15:12:18,987||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078738.986012130","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:12:18,994||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 26095 exited with status 2
Process Process-76:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078748.382479548","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:12:28,383||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078748.382649075","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:12:28,389||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 26125 exited with status 2
2021-06-07 15:12:28,392||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 26138 exited with status 1
Process Process-78:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623078755.652443508","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:12:35,660||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 26157 exited with status 1
2021-06-07 15:18:00,920||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079080.919449922","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:18:00,932||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 26155 exited with status 2
2021-06-07 15:18:45,234||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079125.233527886","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:18:45,236||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 302, in get_prefix_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079125.235396028","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 318, in get_prefix
range_response = self.get_prefix_response(key_prefix, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:18:45,243||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 26179 exited with status 2
2021-06-07 15:18:45,247||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 27986 exited with status 2
Process Process-81:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079132.267803304","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:18:52,278||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 28138 exited with status 1
2021-06-07 15:23:00,443||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079380.442442329","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 134, in row_read
return self.get_values_prefix(key_prefix, pk_name, pk_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 80, in get_values_prefix
for kv in self.get_client().get_prefix(key_prefix)}
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:23:00,453||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 28139 exited with status 2
2021-06-07 15:23:00,881||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079380.879411664","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:23:00,897||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 28152 exited with status 2
Process Process-85:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079387.920400033","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:23:07,931||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 29697 exited with status 1
2021-06-07 15:24:40,517||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079480.516316441","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 202, in __check_for_templates
translating_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TRANSLATING)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:24:40,519||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 46, in handler
return f(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 257, in get_response
return self.kvstub.Range(
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079480.518664392","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 283, in get
range_response = self.get_response(key, **kwargs)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 48, in handler
_translate_exception(exc)
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 32, in _translate_exception
raise exception
etcd3.exceptions.ConnectionFailedError: etcd connection failed
2021-06-07 15:24:40,526||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 29693 exited with status 2
2021-06-07 15:24:40,531||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 29721 exited with status 2
Process Process-88:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079487.551257913","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:24:47,562||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 30283 exited with status 1
2021-06-07 15:24:54,552||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079494.551620609","description":"Error received from peer ipv4:10.242.80.211:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 478, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 336, in __check_for_messages
self._do()
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 343, in _do
msgs = self.RPC.query.all()
File "/opt/has/conductor/conductor/common/music/model/search.py", line 80, in all
rows = db_backend.DB_API.row_read(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:24:54,560||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 30282 exited with status 2
Process Process-89:
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079494.579638660","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 315, in _bootstrap
self.run()
File "/usr/local/lib/python3.9/multiprocessing/process.py", line 108, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 63, in _bootstrap_process
target(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 161, in create_and_wait
sw = cls(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 175, in __init__
self.service = config.service(worker_id, *args, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 78, in __init__
self._init(conf, **kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 88, in _init
self.data_service = self.setup_rpc(conf, "data")
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 139, in setup_rpc
target = music_messaging.Target(topic=topic)
File "/opt/has/conductor/conductor/common/music/messaging/component.py", line 103, in __init__
self._topic_class = base.create_dynamic_model(
File "/opt/has/conductor/conductor/common/music/model/base.py", line 186, in create_dynamic_model
model.table_create()
File "/opt/has/conductor/conductor/common/music/model/base.py", line 70, in table_create
db_backend.DB_API.table_create(**kwargs)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 100, in table_create
self.get_client().put_if_not_exists(table_key, table_value)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:24:54,589||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 30307 exited with status 1
2021-06-07 15:33:06,280||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623079986.278414410","description":"Error received from peer ipv4:10.242.168.23:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:33:06,290||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 30322 exited with status 2
2021-06-07 15:33:25,517||139732314811168|ERROR|_utils|cotyledon._utils: [-] Unhandled exception
Traceback (most recent call last):
File "/opt/has/conductor/conductor/common/etcd/api.py", line 60, in get_client
return etcd3.client(host=self.host, port=self.port,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 1178, in client
return Etcd3Client(host=host,
File "/usr/local/lib/python3.9/site-packages/etcd3/client.py", line 148, in __init__
resp = self.auth_stub.Authenticate(auth_request, self.timeout)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 946, in __call__
return _end_unary_response_blocking(state, call, False, None)
File "/usr/local/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "etcdserver: request timed out"
debug_error_string = "{"created":"@1623080005.516067116","description":"Error received from peer ipv4:10.242.207.141:2379","file":"src/core/lib/surface/call.cc","file_line":1067,"grpc_message":"etcdserver: request timed out","grpc_status":14}"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/cotyledon/_utils.py", line 95, in exit_on_exception
yield
File "/usr/local/lib/python3.9/site-packages/cotyledon/_service.py", line 139, in _run
self.run()
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 256, in run
fut.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/futurist/_utils.py", line 49, in run
result = self.fn(*self.args, **self.kwargs)
File "/opt/has/conductor/conductor/controller/translator_svc.py", line 201, in __check_for_templates
template_plans = self.Plan.query.get_plan_by_col("status", self.Plan.TEMPLATE)
File "/opt/has/conductor/conductor/common/music/model/search.py", line 87, in get_plan_by_col
rows = db_backend.DB_API.row_read(
File "/opt/has/conductor/conductor/common/etcd/api.py", line 128, in row_read
schema = self.get_value(f'{keyspace}/{table}')
File "/opt/has/conductor/conductor/common/etcd/api.py", line 73, in get_value
raw_value = self.get_raw_value(key)
File "/opt/has/conductor/conductor/common/etcd/api.py", line 70, in get_raw_value
return self.get_client().get(key)[0]
File "/opt/has/conductor/conductor/common/etcd/api.py", line 67, in get_client
raise EtcdClientException("Failed to establish connection with ETCD. GRPC {}".format(rpc_error.code()))
conductor.common.etcd.utils.EtcdClientException: Failed to establish connection with ETCD. GRPC StatusCode.UNAVAILABLE
2021-06-07 15:33:25,526||139732316932896|INFO|_service_manager|cotyledon._service_manager: [-] Child 383 exited with status 2