diff --git a/airbyte_rock/rockcraft.yaml b/airbyte_rock/rockcraft.yaml index 172095a..3177272 100644 --- a/airbyte_rock/rockcraft.yaml +++ b/airbyte_rock/rockcraft.yaml @@ -4,7 +4,7 @@ name: airbyte summary: Airbyte rock description: Airbyte OCI image for the Airbyte charm -version: "1.0" +version: "1.0.0" base: ubuntu@22.04 license: Apache-2.0 platforms: @@ -49,7 +49,7 @@ parts: plugin: dump source: https://github.com/airbytehq/airbyte-platform.git # yamllint disable-line source-type: git - source-tag: v1.1.0 + source-tag: v1.0.0 override-build: | cp -r . ${CRAFT_PART_INSTALL}/airbyte-platform stage: diff --git a/src/literals.py b/src/literals.py index 59afe17..377873a 100644 --- a/src/literals.py +++ b/src/literals.py @@ -8,7 +8,7 @@ AIRBYTE_API_PORT = 8006 WORKLOAD_API_PORT = 8007 WORKLOAD_LAUNCHER_PORT = 8016 -AIRBYTE_VERSION = "1.1.0" +AIRBYTE_VERSION = "1.0.0" DB_NAME = "airbyte-k8s_db" diff --git a/tests/integration/helpers.py b/tests/integration/helpers.py index c31020b..552f75a 100644 --- a/tests/integration/helpers.py +++ b/tests/integration/helpers.py @@ -224,26 +224,23 @@ def create_airbyte_connection(api_url, source_id, destination_id): Returns: Created connection ID. """ - try: - url = f"{api_url}/api/public/v1/connections" - payload = { - "schedule": {"scheduleType": "manual"}, - "dataResidency": "auto", - "namespaceDefinition": "destination", - "namespaceFormat": None, - "nonBreakingSchemaUpdatesBehavior": "ignore", - "sourceId": source_id, - "destinationId": destination_id, - } - - logger.info("creating Airbyte connection") - response = requests.post(url, json=payload, headers=POST_HEADERS, timeout=900) - logger.info(response.json()) - - assert response.status_code == 200 - return response.json().get("connectionId") - except Exception as e: - logger.error(f"Error creating Airbyte connection: {e}") + url = f"{api_url}/api/public/v1/connections" + payload = { + "schedule": {"scheduleType": "manual"}, + "dataResidency": "auto", + "namespaceDefinition": "destination", + "namespaceFormat": None, + "nonBreakingSchemaUpdatesBehavior": "ignore", + "sourceId": source_id, + "destinationId": destination_id, + } + + logger.info("creating Airbyte connection") + response = requests.post(url, json=payload, headers=POST_HEADERS, timeout=900) + logger.info(response.json()) + + assert response.status_code == 200 + return response.json().get("connectionId") def trigger_airbyte_connection(api_url, connection_id):