SAT: verify AIRBYTE_ENTRYPOINT is defined

airbyte-integrations/bases/source-acceptance-test/CHANGELOG.md

@@ -5,3 +5,7 @@ Add test whether PKs present and not None if `source_defined_primary_key` define
 
 ## 0.1.5
 Add configurable timeout for the acceptance tests: https://github.com/airbytehq/airbyte/pull/4296
+
+## 0.1.7
+Add: `test_spec` additionally checks if Dockerfile has `ENV AIRBYTE_ENTRYPOINT` defined 
+    and equal to space_joined `ENTRYPOINT`

airbyte-integrations/bases/source-acceptance-test/Dockerfile

@@ -8,7 +8,7 @@ COPY setup.py ./
 COPY pytest.ini ./
 RUN pip install .
 
-LABEL io.airbyte.version=0.1.6
+LABEL io.airbyte.version=0.1.7
 LABEL io.airbyte.name=airbyte/source-acceptance-test
 
 ENTRYPOINT ["python", "-m", "pytest", "-p", "source_acceptance_test.plugin"]

airbyte-integrations/bases/source-acceptance-test/source_acceptance_test/tests/test_core.py

@@ -45,6 +45,11 @@ def test_spec(self, connector_spec: ConnectorSpecification, docker_runner: Conne
         if connector_spec:
             assert spec_messages[0].spec == connector_spec, "Spec should be equal to the one in spec.json file"
 
+        assert docker_runner.env_variables.get("AIRBYTE_ENTRYPOINT"), "AIRBYTE_ENTRYPOINT must be set in dockerfile"
+        assert docker_runner.env_variables.get("AIRBYTE_ENTRYPOINT") == " ".join(
+            docker_runner.entry_point
+        ), "env should be equal to space-joined entrypoint"
+
 
 @pytest.mark.default_timeout(30)
 class TestConnection(BaseTest):

airbyte-integrations/bases/source-acceptance-test/source_acceptance_test/utils/connector_runner.py

@@ -130,3 +130,12 @@ def run(self, cmd, config=None, state=None, catalog=None, **kwargs) -> Iterable[
                 yield AirbyteMessage.parse_raw(line)
             except ValidationError as exc:
                 logging.warning("Unable to parse connector's output %s", exc)
+
+    @property
+    def env_variables(self):
+        env_vars = self._image.attrs["Config"]["Env"]
+        return {env.split("=", 1)[0]: env.split("=", 1)[1] for env in env_vars}
+
+    @property
+    def entry_point(self):
+        return self._image.attrs["Config"]["Entrypoint"]