Skip to content

Commit

Permalink
downgrade to v1.0.0
Browse files Browse the repository at this point in the history
  • Loading branch information
kelkawi-a committed Nov 1, 2024
1 parent 9da29cb commit 01b0f3d
Show file tree
Hide file tree
Showing 3 changed files with 20 additions and 23 deletions.
4 changes: 2 additions & 2 deletions airbyte_rock/rockcraft.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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: [email protected]
license: Apache-2.0
platforms:
Expand Down Expand Up @@ -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:
Expand Down
2 changes: 1 addition & 1 deletion src/literals.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"


Expand Down
37 changes: 17 additions & 20 deletions tests/integration/helpers.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down

0 comments on commit 01b0f3d

Please sign in to comment.