Extract SQL from rawSql and rawSQL

[dgluong-datahub]

No description provided.

[codecov]

❌ 1 Tests Failed:

Tests completed	Failed	Passed	Skipped
5296	1	5295	32

View the top 1 failed test(s) by shortest run time

tests.integration.kafka-connect-confluent-cloud.test_kafka_connect_confluent_cloud::test_kafka_connect_confluent_cloud_ingest

Stack Traces | 60.9s run time

docker_compose_runner = <function docker_compose_runner.<locals>.run at 0x7f02f4f61760>
pytestconfig = <_pytest.config.Config object at 0x7f03d68d1290>
test_resources_dir = PosixPath('.../tests/integration/kafka-connect-confluent-cloud')

    @pytest.fixture(scope="module")
    def confluent_cloud_mock_runner(
        docker_compose_runner, pytestconfig, test_resources_dir
    ):
        docker_compose_file = [str(test_resources_dir / "docker-compose.override.yml")]
    
>       with docker_compose_runner(
            docker_compose_file, "kafka-connect-confluent-cloud"
        ) as docker_services:

.../integration/kafka-connect-confluent-cloud/test_kafka_connect_confluent_cloud.py:45: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
.../hostedtoolcache/Python/3.11.14....../x64/lib/python3.11/contextlib.py:137: in __enter__
    return next(self.gen)
           ^^^^^^^^^^^^^^
.../datahub/testing/docker_utils.py:65: in run
    with pytest_docker.plugin.get_docker_services(
.../hostedtoolcache/Python/3.11.14....../x64/lib/python3.11/contextlib.py:137: in __enter__
    return next(self.gen)
           ^^^^^^^^^^^^^^
venv/lib/python3.11........./site-packages/pytest_docker/plugin.py:212: in get_docker_services
    docker_compose.execute(command)
venv/lib/python3.11........./site-packages/pytest_docker/plugin.py:140: in execute
    return execute(command, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

command = 'docker compose --parallel -1 -f ".../tests/integration/kafka-connect-confluent-cloud/docker-compose.override.yml" -p "pytest4947-kafka-connect-confluent-cloud" up --build --wait'
success_codes = (0,), ignore_stderr = False

    def execute(command: str, success_codes: Iterable[int] = (0,), ignore_stderr: bool = False) -> Union[bytes, Any]:
        """Run a shell command."""
        try:
            stderr_pipe = subprocess.DEVNULL if ignore_stderr else subprocess.STDOUT
            output = subprocess.check_output(command, stderr=stderr_pipe, shell=True)
            status = 0
        except subprocess.CalledProcessError as error:
            output = error.output or b""
            status = error.returncode
            command = error.cmd
    
        if status not in success_codes:
>           raise Exception(
                'Command {} returned {}: """{}""".'.format(command, status, output.decode("utf-8"))
            )
E           Exception: Command docker compose --parallel -1 -f ".../tests/integration/kafka-connect-confluent-cloud/docker-compose.override.yml" -p "pytest4947-kafka-connect-confluent-cloud" up --build --wait returned 1: """#1 [internal] load local bake definitions
E           #1 reading from stdin 578B done
E           #1 DONE 0.0s
E           
E           #2 [internal] load build definition from Dockerfile
E           #2 transferring dockerfile: 364B done
E           #2 DONE 0.0s
E           
E           #3 [internal] load metadata for docker.io/library/python:3.11-slim
E           #3 DONE 0.2s
E           
E           #4 [internal] load .dockerignore
E           #4 transferring context: 2B done
E           #4 DONE 0.0s
E           
E           #5 [internal] load build context
E           #5 transferring context: 18.80kB done
E           #5 DONE 0.0s
E           
E           #6 [1/4] FROM docker.io/library/python:3.11-slim@sha256:b9896ddef33d916fe0c8fadc206167527a2527c28232342345f5ea51ebfbb3ad
E           #6 resolve docker.io/library/python:3.11-slim@sha256:b9896ddef33d916fe0c8fadc206167527a2527c28232342345f5ea51ebfbb3ad done
E           #6 sha256:b9896ddef33d916fe0c8fadc206167527a2527c28232342345f5ea51ebfbb3ad 10.37kB / 10.37kB done
E           #6 sha256:c4116d4d7ea9320db352f6516001262753529edf1e20b2c6609a6b9a49cc6be4 1.75kB / 1.75kB done
E           #6 sha256:040af88f5bce9e9239b7e739e86304d26964d1d55ada56b9297a3d891e91634d 5.48kB / 5.48kB done
E           #6 sha256:0e4bc2bd6656e6e004e3c749af70e5650bac2258243eb0949dea51cb8b7863db 7.45MB / 29.78MB 0.1s
E           #6 sha256:22b63e76fde1e200371ed9f3cee91161d192063bcff65c9ab6bf63819810a974 1.29MB / 1.29MB 0.1s done
E           #6 sha256:b3dd773c329649f22e467ae63d1c612a039a0559dec99ffb9ada904ab5c60c55 7.34MB / 14.36MB 0.1s
E           #6 sha256:1771569cc1299abc9cc762fc4419523e721b11a3927ef968ae63ba0a4a88f2da 0B / 251B 0.1s
E           #6 sha256:0e4bc2bd6656e6e004e3c749af70e5650bac2258243eb0949dea51cb8b7863db 28.31MB / 29.78MB 0.3s
E           #6 sha256:b3dd773c329649f22e467ae63d1c612a039a0559dec99ffb9ada904ab5c60c55 14.36MB / 14.36MB 0.2s done
E           #6 sha256:1771569cc1299abc9cc762fc4419523e721b11a3927ef968ae63ba0a4a88f2da 251B / 251B 0.1s done
E           #6 sha256:0e4bc2bd6656e6e004e3c749af70e5650bac2258243eb0949dea51cb8b7863db 29.78MB / 29.78MB 0.3s done
E           #6 extracting sha256:0e4bc2bd6656e6e004e3c749af70e5650bac2258243eb0949dea51cb8b7863db 0.1s
E           #6 extracting sha256:0e4bc2bd6656e6e004e3c749af70e5650bac2258243eb0949dea51cb8b7863db 0.5s done
E           #6 extracting sha256:22b63e76fde1e200371ed9f3cee91161d192063bcff65c9ab6bf63819810a974 0.1s done
E           #6 extracting sha256:b3dd773c329649f22e467ae63d1c612a039a0559dec99ffb9ada904ab5c60c55
E           #6 extracting sha256:b3dd773c329649f22e467ae63d1c612a039a0559dec99ffb9ada904ab5c60c55 0.4s done
E           #6 extracting sha256:1771569cc1299abc9cc762fc4419523e721b11a3927ef968ae63ba0a4a88f2da done
E           #6 DONE 1.6s
E           
E           #7 [2/4] WORKDIR /app
E           #7 DONE 0.0s
E           
E           #8 [3/4] COPY confluent_cloud_mock_api.py ./
E           #8 DONE 0.0s
E           
E           #9 [4/4] RUN pip install --no-cache-dir flask
E           #9 1.644 Collecting flask
E           #9 1.665   Downloading flask-3.1.2-py3-none-any.whl.metadata (3.2 kB)
E           #9 1.678 Collecting blinker>=1.9.0 (from flask)
E           #9 1.682   Downloading blinker-1.9.0-py3-none-any.whl.metadata (1.6 kB)
E           #9 1.697 Collecting click>=8.1.3 (from flask)
E           #9 1.699   Downloading click-8.3.1-py3-none-any.whl.metadata (2.6 kB)
E           #9 1.709 Collecting itsdangerous>=2.2.0 (from flask)
E           #9 1.711   Downloading itsdangerous-2.2.0-py3-none-any.whl.metadata (1.9 kB)
E           #9 1.727 Collecting jinja2>=3.1.2 (from flask)
E           #9 1.734   Downloading jinja2-3.1.6-py3-none-any.whl.metadata (2.9 kB)
E           #9 1.773 Collecting markupsafe>=2.1.1 (from flask)
E           #9 1.776   Downloading markupsafe-3.0.3-cp311-cp311-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl.metadata (2.7 kB)
E           #9 1.796 Collecting werkzeug>=3.1.0 (from flask)
E           #9 1.800   Downloading werkzeug-3.1.3-py3-none-any.whl.metadata (3.7 kB)
E           #9 1.811 Downloading flask-3.1.2-py3-none-any.whl (103 kB)
E           #9 1.814    ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 103.3/103.3 kB 123.3 MB/s eta 0:00:00
E           #9 1.821 Downloading blinker-1.9.0-py3-none-any.whl (8.5 kB)
E           #9 1.833 Downloading click-8.3.1-py3-none-any.whl (108 kB)
E           #9 1.836    ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 108.3/108.3 kB 47.5 MB/s eta 0:00:00
E           #9 1.858 Downloading itsdangerous-2.2.0-py3-none-any.whl (16 kB)
E           #9 1.876 Downloading jinja2-3.1.6-py3-none-any.whl (134 kB)
E           #9 1.877    ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 134.9/134.9 kB 582.8 MB/s eta 0:00:00
E           #9 1.881 Downloading markupsafe-3.0.3-cp311-cp311-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl (22 kB)
E           #9 1.886 Downloading werkzeug-3.1.3-py3-none-any.whl (224 kB)
E           #9 1.887    ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 224.5/224.5 kB 613.2 MB/s eta 0:00:00
E           #9 1.922 Installing collected packages: markupsafe, itsdangerous, click, blinker, werkzeug, jinja2, flask
E           #9 2.167 Successfully installed blinker-1.9.0 click-8.3.1 flask-3.1.2 itsdangerous-2.2.0 jinja2-3.1.6 markupsafe-3.0.3 werkzeug-3.1.3
E           #9 2.167 WARNING: Running pip as the 'root' user can result in broken permissions and conflicting behaviour with the system package manager. It is recommended to use a virtual environment instead: https://pip.pypa.io/warnings/venv
E           #9 2.211 
E           #9 2.211 [notice] A new release of pip is available: 24.0 -> 25.3
E           #9 2.211 [notice] To update, run: pip install --upgrade pip
E           #9 DONE 2.3s
E           
E           #10 exporting to image
E           #10 exporting layers
E           #10 exporting layers 0.3s done
E           #10 writing image sha256:c26474eede27503e1a2c5e81cfef1bcfd83b89d0d51c62c1e12890571bd653c9 done
E           #10 naming to docker.io/library/pytest4947-kafka-connect-confluent-cloud-confluent-cloud-mock done
E           #10 DONE 0.3s
E           
E           #11 resolving provenance for metadata file
E           #11 DONE 0.0s
E            confluent-cloud-mock  Built
E            Network pytest4947-kafka-connect-confluent-cloud_default  Creating
E            Network pytest4947-kafka-connect-confluent-cloud_default  Created
E            Container test_confluent_cloud_mock  Creating
E            Container test_confluent_cloud_mock  Created
E            Container test_confluent_cloud_mock  Starting
E            Container test_confluent_cloud_mock  Started
E            Container test_confluent_cloud_mock  Waiting
E           container test_confluent_cloud_mock is unhealthy
E           """.

venv/lib/python3.11........./site-packages/pytest_docker/plugin.py:37: Exception

To view more test analytics, go to the Test Analytics Dashboard
_{📋 Got 3 mins? Take this short survey to help us improve Test Analytics.}

[alwaysmeticulous]

✅ Meticulous spotted 0 visual differences across 1015 screens tested: view results.

Meticulous evaluated ~8 hours of user flows against your PR.

_{Expected differences? Click here. Last updated for commit b39a866. This comment will update as new commits are pushed.}