mohamedawnallah commented on PR #35920:
URL: https://github.com/apache/beam/pull/35920#issuecomment-3221643526
> I'm still seeing the precommit coverage workflow failing with similar
errors unfortunately:
>
> ```
> <testcase
classname="apache_beam.ml.rag.enrichment.milvus_search_it_test.TestMilvusSearchEnrichment"
name="test_keyword_search_with_inner_product_sparse_embedding" time="0.001">
> <error message="failed on setup with "Failed: Timeout (>600.0s) from
pytest-timeout."">wrapped = <bound method DockerContainer.get_exposed_port of
<apache_beam.ml.rag.enrichment.milvus_search_it_test.CustomMilvusContainer
object at 0x79a1ec603cd0>> instance =
<apache_beam.ml.rag.enrichment.milvus_search_it_test.CustomMilvusContainer
object at 0x79a1ec603cd0> args = (36185,), kwargs = {} @wrapt.decorator # type:
ignore[misc] def wrapper(wrapped: Callable[..., Any], instance: Any, args:
list[Any], kwargs: dict[str, Any]) -> Any: from testcontainers.core.container
import DockerContainer if isinstance(instance, DockerContainer):
logger.info("Waiting for container %s with image %s to be ready ...",
instance._container, instance.image) else: logger.info("Waiting for %s to be
ready ...", instance) exception = None for attempt_no in
range(config.max_tries): try: > return wrapped(*args, **kwargs)
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers
/core/waiting_utils.py:59: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/core/container.py:237:
in get_exposed_port return int(self.get_docker_client().port(c.id, port)) _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <testcontainers.core.docker_client.DockerClient object at
0x79a1ec603d30> container_id =
'feced16dceea3235bfbdda7d020425c9513b4cb37360ab33254292421da7c97d' port = 36185
def port(self, container_id: str, port: int) -> str: """ Lookup the
public-facing port that is NAT-ed to :code:`port`. """ port_mappings =
self.client.api.port(container_id, port) if not port_mappings: > raise
ConnectionError(f"Port mapping for container {container_id} and port {port} is
not available") E ConnectionError: Port mapping for container
feced16dceea3235bfbdda7d020425c9513b4cb37360ab33254292421da7c97d and port 36185
is not availa
ble
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/core/docker_client.py:170:
ConnectionError During handling of the above exception, another exception
occurred: cls = <class
'apache_beam.ml.rag.enrichment.milvus_search_it_test.TestMilvusSearchEnrichment'>
@classmethod def setUpClass(cls): > cls._db =
MilvusEnrichmentTestHelper.start_db_container(cls._version)
apache_beam/ml/rag/enrichment/milvus_search_it_test.py:488: _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/ml/rag/enrichment/milvus_search_it_test.py:318: in
start_db_container vector_db_container.start()
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/milvus/__init__.py:83:
in start self._connect()
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/core/waiting_utils.py:59:
in wrapper return wrapped(*args, **kwargs) target/.tox-py39-cloudcoverage/py39
-cloudcoverage/lib/python3.9/site-packages/testcontainers/milvus/__init__.py:65:
in _connect self._healthcheck()
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/core/waiting_utils.py:59:
in wrapper return wrapped(*args, **kwargs)
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/milvus/__init__.py:74:
in _healthcheck healthcheck_url = self._get_healthcheck_url()
target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/milvus/__init__.py:69:
in _get_healthcheck_url port = self.get_exposed_port(self.healthcheck_port) _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
wrapped = <bound method DockerContainer.get_exposed_port of
<apache_beam.ml.rag.enrichment.milvus_search_it_test.CustomMilvusContainer
object at 0x79a1ec603cd0>> instance =
<apache_beam.ml.rag.enrichment.milvus_search_it_test.CustomMilvusContainer
object at 0x79a1ec603cd0
> args = (36185,), kwargs = {} @wrapt.decorator # type: ignore[misc] def
> wrapper(wrapped: Callable[..., Any], instance: Any, args: list[Any], kwargs:
> dict[str, Any]) -> Any: from testcontainers.core.container import
> DockerContainer if isinstance(instance, DockerContainer):
> logger.info("Waiting for container %s with image %s to be ready ...",
> instance._container, instance.image) else: logger.info("Waiting for %s to be
> ready ...", instance) exception = None for attempt_no in
> range(config.max_tries): try: return wrapped(*args, **kwargs) except
> transient_exceptions as e: logger.debug( f"Connection attempt '{attempt_no +
> 1}' of '{config.max_tries + 1}' " f"failed: {traceback.format_exc()}" ) >
> time.sleep(config.sleep_time) E Failed: Timeout (>600.0s) from
> pytest-timeout.
> target/.tox-py39-cloudcoverage/py39-cloudcoverage/lib/python3.9/site-packages/testcontainers/core/waiting_utils.py:65:
> Failed</error>
> ```
This PR #35954 would address this issue
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
