diff --git a/src/context/tests/context_report.xml b/src/context/tests/context_report.xml deleted file mode 100644 index 5ee1c17cd6f59c58d55a5eba38de7ea0366a757c..0000000000000000000000000000000000000000 --- a/src/context/tests/context_report.xml +++ /dev/null @@ -1,1539 +0,0 @@ -<?xml version="1.0" encoding="utf-8"?><testsuites><testsuite name="pytest" errors="0" failures="25" skipped="0" tests="51" time="8.764" timestamp="2022-07-29T09:29:23.786468" hostname="613b7e973910"><testcase classname="context.tests.test_unitary" name="test_grpc_context[all_inmemory]" time="0.028" /><testcase classname="context.tests.test_unitary" name="test_grpc_topology[all_inmemory]" time="0.026" /><testcase classname="context.tests.test_unitary" name="test_grpc_device[all_inmemory]" time="0.139" /><testcase classname="context.tests.test_unitary" name="test_grpc_link[all_inmemory]" time="0.139" /><testcase classname="context.tests.test_unitary" name="test_grpc_service[all_inmemory]" time="0.152" /><testcase classname="context.tests.test_unitary" name="test_grpc_connection[all_inmemory]" time="0.274" /><testcase classname="context.tests.test_unitary" name="test_rest_populate_database[all_inmemory]" time="0.093" /><testcase classname="context.tests.test_unitary" name="test_rest_get_context_ids[all_inmemory]" time="1.033" /><testcase classname="context.tests.test_unitary" name="test_rest_get_contexts[all_inmemory]" time="0.009" /><testcase classname="context.tests.test_unitary" name="test_rest_get_context[all_inmemory]" time="0.009" /><testcase classname="context.tests.test_unitary" name="test_rest_get_topology_ids[all_inmemory]" time="0.006" /><testcase classname="context.tests.test_unitary" name="test_rest_get_topologies[all_inmemory]" time="0.013" /><testcase classname="context.tests.test_unitary" name="test_rest_get_topology[all_inmemory]" time="0.012" /><testcase classname="context.tests.test_unitary" name="test_rest_get_service_ids[all_inmemory]" time="0.007" /><testcase classname="context.tests.test_unitary" name="test_rest_get_services[all_inmemory]" time="0.039" /><testcase classname="context.tests.test_unitary" name="test_rest_get_service[all_inmemory]" time="0.017" /><testcase classname="context.tests.test_unitary" name="test_rest_get_device_ids[all_inmemory]" time="0.005" /><testcase classname="context.tests.test_unitary" name="test_rest_get_devices[all_inmemory]" time="0.070" /><testcase classname="context.tests.test_unitary" name="test_rest_get_device[all_inmemory]" time="0.027" /><testcase classname="context.tests.test_unitary" name="test_rest_get_link_ids[all_inmemory]" time="0.005" /><testcase classname="context.tests.test_unitary" name="test_rest_get_links[all_inmemory]" time="0.023" /><testcase classname="context.tests.test_unitary" name="test_rest_get_link[all_inmemory]" time="0.011" /><testcase classname="context.tests.test_unitary" name="test_rest_get_connection_ids[all_inmemory]" time="0.007" /><testcase classname="context.tests.test_unitary" name="test_rest_get_connections[all_inmemory]" time="0.032" /><testcase classname="context.tests.test_unitary" name="test_rest_get_connection[all_inmemory]" time="0.032" /><testcase classname="context.tests.test_unitary" name="test_grpc_context[all_redis]" time="0.477"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb01a79edc0> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb0186538b0> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_client_grpc = <context.client.ContextClient.ContextClient object at 0x7fb018f15a30> -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) - - def test_grpc_context( - context_client_grpc : ContextClient, # pylint: disable=redefined-outer-name - context_db_mb : Tuple[Database, MessageBroker]): # pylint: disable=redefined-outer-name - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- -> context_database.clear_all() - -context/tests/test_unitary.py:128: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_grpc_topology[all_redis]" time="0.002"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb018563b80> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb018587550> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_client_grpc = <context.client.ContextClient.ContextClient object at 0x7fb018f15a30> -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) - - def test_grpc_topology( - context_client_grpc : ContextClient, # pylint: disable=redefined-outer-name - context_db_mb : Tuple[Database, MessageBroker]): # pylint: disable=redefined-outer-name - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- -> context_database.clear_all() - -context/tests/test_unitary.py:249: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_grpc_device[all_redis]" time="0.001"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb018683820> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb018653f70> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_client_grpc = <context.client.ContextClient.ContextClient object at 0x7fb018f15a30> -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) - - def test_grpc_device( - context_client_grpc : ContextClient, # pylint: disable=redefined-outer-name - context_db_mb : Tuple[Database, MessageBroker]): # pylint: disable=redefined-outer-name - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- -> context_database.clear_all() - -context/tests/test_unitary.py:381: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_grpc_link[all_redis]" time="0.001"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb0186c0550> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb0186c0670> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_client_grpc = <context.client.ContextClient.ContextClient object at 0x7fb018f15a30> -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) - - def test_grpc_link( - context_client_grpc : ContextClient, # pylint: disable=redefined-outer-name - context_db_mb : Tuple[Database, MessageBroker]): # pylint: disable=redefined-outer-name - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- -> context_database.clear_all() - -context/tests/test_unitary.py:556: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_grpc_service[all_redis]" time="0.001"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb018f2f700> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb0186188b0> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_client_grpc = <context.client.ContextClient.ContextClient object at 0x7fb018f15a30> -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) - - def test_grpc_service( - context_client_grpc : ContextClient, # pylint: disable=redefined-outer-name - context_db_mb : Tuple[Database, MessageBroker]): # pylint: disable=redefined-outer-name - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- -> context_database.clear_all() - -context/tests/test_unitary.py:739: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_grpc_connection[all_redis]" time="0.001"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb0186a43a0> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb0186a4310> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_client_grpc = <context.client.ContextClient.ContextClient object at 0x7fb018f15a30> -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) - - def test_grpc_connection( - context_client_grpc : ContextClient, # pylint: disable=redefined-outer-name - context_db_mb : Tuple[Database, MessageBroker]): # pylint: disable=redefined-outer-name - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- -> context_database.clear_all() - -context/tests/test_unitary.py:926: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_populate_database[all_redis]" time="0.001"><failure message="redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused.">self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: -> sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:607: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = <redis.retry.Retry object at 0x7fb0186487f0> -do = <function Connection.connect.<locals>.<lambda> at 0x7fb0186d49d0> -fail = <function Connection.connect.<locals>.<lambda> at 0x7fb0186d4280> - - def call_with_retry(self, do, fail): - """ - Execute an operation that might fail and returns its result, or - raise the exception that was thrown depending on the `Backoff` object. - `do`: the operation to call. Expects no argument. - `fail`: the failure handler, expects the last error that was thrown - """ - self._backoff.reset() - failures = 0 - while True: - try: -> return do() - -/usr/local/lib/python3.9/site-packages/redis/retry.py:45: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -> lambda: self._connect(), lambda error: self.disconnect(error) - ) - -/usr/local/lib/python3.9/site-packages/redis/connection.py:608: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect - sock.connect(socket_address) - - # set the socket_timeout now that we're connected - sock.settimeout(self.socket_timeout) - return sock - - except OSError as _: - err = _ - if sock is not None: - sock.close() - - if err is not None: -> raise err - -/usr/local/lib/python3.9/site-packages/redis/connection.py:673: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def _connect(self): - "Create a TCP socket connection" - # we want to mimic what socket.create_connection does to support - # ipv4/ipv6, but we want to set options prior to calling - # socket.connect() - err = None - for res in socket.getaddrinfo( - self.host, self.port, self.socket_type, socket.SOCK_STREAM - ): - family, socktype, proto, canonname, socket_address = res - sock = None - try: - sock = socket.socket(family, socktype, proto) - # TCP_NODELAY - sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) - - # TCP_KEEPALIVE - if self.socket_keepalive: - sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) - for k, v in self.socket_keepalive_options.items(): - sock.setsockopt(socket.IPPROTO_TCP, k, v) - - # set the socket_connect_timeout before we connect - sock.settimeout(self.socket_connect_timeout) - - # connect -> sock.connect(socket_address) -E ConnectionRefusedError: [Errno 111] Connection refused - -/usr/local/lib/python3.9/site-packages/redis/connection.py:661: ConnectionRefusedError - -During handling of the above exception, another exception occurred: - -context_db_mb = (<common.orm.Database.Database object at 0x7fb018f15910>, <common.message_broker.MessageBroker.MessageBroker object at 0x7fb018f15460>) -context_service_grpc = <context.service.grpc_server.ContextService.ContextService object at 0x7fb018f158e0> - - def test_rest_populate_database( - context_db_mb : Tuple[Database, MessageBroker], # pylint: disable=redefined-outer-name - context_service_grpc : ContextService # pylint: disable=redefined-outer-name - ): - database = context_db_mb[0] -> database.clear_all() - -context/tests/test_unitary.py:1179: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ -common/orm/Database.py:32: in clear_all - for key in self._backend.keys(): -common/orm/backend/redis/RedisBackend.py:48: in keys - return [k.decode('UTF-8') for k in self._client.keys()] -/usr/local/lib/python3.9/site-packages/redis/commands/core.py:1370: in keys - return self.execute_command("KEYS", pattern, **kwargs) -/usr/local/lib/python3.9/site-packages/redis/client.py:1173: in execute_command - conn = self.connection or pool.get_connection(command_name, **options) -/usr/local/lib/python3.9/site-packages/redis/connection.py:1370: in get_connection - connection.connect() -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -self = Connection<host=127.0.0.1,port=6379,db=0> - - def connect(self): - "Connects to the Redis server if not already connected" - if self._sock: - return - try: - sock = self.retry.call_with_retry( - lambda: self._connect(), lambda error: self.disconnect(error) - ) - except socket.timeout: - raise TimeoutError("Timeout connecting to server") - except OSError as e: -> raise ConnectionError(self._error_message(e)) -E redis.exceptions.ConnectionError: Error 111 connecting to 127.0.0.1:6379. Connection refused. - -/usr/local/lib/python3.9/site-packages/redis/connection.py:613: ConnectionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_context_ids[all_redis]" time="1.033"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_context_ids(context_service_rest : RestServer): # pylint: disable=redefined-outer-name -> reply = do_rest_request('/context_ids') - -context/tests/test_unitary.py:1183: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context_ids' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_contexts[all_redis]" time="0.006"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_contexts(context_service_rest : RestServer): # pylint: disable=redefined-outer-name -> reply = do_rest_request('/contexts') - -context/tests/test_unitary.py:1187: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/contexts' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_context[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_context(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) -> reply = do_rest_request('/context/{:s}'.format(context_uuid)) - -context/tests/test_unitary.py:1192: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_topology_ids[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_topology_ids(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) -> reply = do_rest_request('/context/{:s}/topology_ids'.format(context_uuid)) - -context/tests/test_unitary.py:1197: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/topology_ids' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_topologies[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_topologies(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) -> reply = do_rest_request('/context/{:s}/topologies'.format(context_uuid)) - -context/tests/test_unitary.py:1202: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/topologies' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_topology[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_topology(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) - topology_uuid = urllib.parse.quote(DEFAULT_TOPOLOGY_UUID) -> reply = do_rest_request('/context/{:s}/topology/{:s}'.format(context_uuid, topology_uuid)) - -context/tests/test_unitary.py:1208: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/topology/admin' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_service_ids[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_service_ids(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) -> reply = do_rest_request('/context/{:s}/service_ids'.format(context_uuid)) - -context/tests/test_unitary.py:1213: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/service_ids' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_services[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_services(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) -> reply = do_rest_request('/context/{:s}/services'.format(context_uuid)) - -context/tests/test_unitary.py:1218: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/services' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_service[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_service(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) - service_uuid = urllib.parse.quote(SERVICE_R1_R2_UUID, safe='') -> reply = do_rest_request('/context/{:s}/service/{:s}'.format(context_uuid, service_uuid)) - -context/tests/test_unitary.py:1224: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/service/SVC%3AR1%2FEP100-R2%2FEP100' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_device_ids[all_redis]" time="0.006"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_device_ids(context_service_rest : RestServer): # pylint: disable=redefined-outer-name -> reply = do_rest_request('/device_ids') - -context/tests/test_unitary.py:1228: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/device_ids' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_devices[all_redis]" time="0.006"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_devices(context_service_rest : RestServer): # pylint: disable=redefined-outer-name -> reply = do_rest_request('/devices') - -context/tests/test_unitary.py:1232: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/devices' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_device[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_device(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - device_uuid = urllib.parse.quote(DEVICE_R1_UUID, safe='') -> reply = do_rest_request('/device/{:s}'.format(device_uuid)) - -context/tests/test_unitary.py:1237: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/device/R1' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_link_ids[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_link_ids(context_service_rest : RestServer): # pylint: disable=redefined-outer-name -> reply = do_rest_request('/link_ids') - -context/tests/test_unitary.py:1241: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/link_ids' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_links[all_redis]" time="0.006"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_links(context_service_rest : RestServer): # pylint: disable=redefined-outer-name -> reply = do_rest_request('/links') - -context/tests/test_unitary.py:1245: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/links' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_link[all_redis]" time="0.008"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_link(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - link_uuid = urllib.parse.quote(LINK_R1_R2_UUID, safe='') -> reply = do_rest_request('/link/{:s}'.format(link_uuid)) - -context/tests/test_unitary.py:1250: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/link/R1%2FEP2-R2%2FEP1' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_connection_ids[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_connection_ids(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) - service_uuid = urllib.parse.quote(SERVICE_R1_R3_UUID, safe='') -> reply = do_rest_request('/context/{:s}/service/{:s}/connection_ids'.format(context_uuid, service_uuid)) - -context/tests/test_unitary.py:1256: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/service/SVC%3AR1%2FEP100-R3%2FEP100/connection_ids' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_connections[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_connections(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - context_uuid = urllib.parse.quote(DEFAULT_CONTEXT_UUID) - service_uuid = urllib.parse.quote(SERVICE_R1_R3_UUID, safe='') -> reply = do_rest_request('/context/{:s}/service/{:s}/connections'.format(context_uuid, service_uuid)) - -context/tests/test_unitary.py:1262: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/context/admin/service/SVC%3AR1%2FEP100-R3%2FEP100/connections' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_rest_get_connection[all_redis]" time="0.007"><failure message="AssertionError: Reply failed with code 500 assert 500 == 200 +500 -200">context_service_rest = <RestServer(Thread-71, started daemon 140392926267136)> - - def test_rest_get_connection(context_service_rest : RestServer): # pylint: disable=redefined-outer-name - connection_uuid = urllib.parse.quote(CONNECTION_R1_R3_UUID, safe='') -> reply = do_rest_request('/connection/{:s}'.format(connection_uuid)) - -context/tests/test_unitary.py:1267: -_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ - -url = '/connection/CON%3AR1%2FEP100-R3%2FEP100' - - def do_rest_request(url : str): - base_url = get_service_baseurl_http(ServiceNameEnum.CONTEXT) - request_url = 'http://{:s}:{:s}{:s}{:s}'.format(str(LOCAL_HOST), str(HTTP_PORT), str(base_url), url) - LOGGER.warning('Request: GET {:s}'.format(str(request_url))) - reply = requests.get(request_url) - LOGGER.warning('Reply: {:s}'.format(str(reply.text))) -> assert reply.status_code == 200, 'Reply failed with code {}'.format(reply.status_code) -E AssertionError: Reply failed with code 500 -E assert 500 == 200 -E +500 -E -200 - -context/tests/test_unitary.py:116: AssertionError</failure></testcase><testcase classname="context.tests.test_unitary" name="test_tools_fast_string_hasher" time="0.423" /></testsuite></testsuites> \ No newline at end of file diff --git a/src/device/tests/device_report.xml b/src/device/tests/device_report.xml deleted file mode 100644 index c05ea0ba79d2b1b6fb5434a76c2e6af022eb2e2c..0000000000000000000000000000000000000000 --- a/src/device/tests/device_report.xml +++ /dev/null @@ -1 +0,0 @@ -<?xml version="1.0" encoding="utf-8"?><testsuites><testsuite name="pytest" errors="0" failures="0" skipped="0" tests="0" time="0.017" timestamp="2022-07-29T09:28:47.168633" hostname="86d45e18bd70" /></testsuites> \ No newline at end of file