PR #801 #1056
GitHub Actions / PyTest Results (Full)
failed
Sep 24, 2025 in 0s
1 fail, 16 skipped, 347 pass in 24m 3s
Annotations
Check warning on line 0 in tests.integration_tests.cloud.test_cloud_workspaces
github-actions / PyTest Results (Full)
test_deploy_connection (tests.integration_tests.cloud.test_cloud_workspaces) failed
build/test-results/test-results.xml [took 28s]
Raw output
airbyte_api.errors.sdkerror.SDKError: API error occurred: Status 500
{"status":500,"type":"https://reference.airbyte.com/reference/errors","title":"unexpected-problem","detail":"An unexpected problem has occurred. If this is an error that needs to be addressed, please submit a pull request or github issue.","documentationUrl":null,"data":{"message":"Secret reference 9841a64b-e357-45e3-ac47-b0f5e1382308 does not exist but is referenced in the config"}}
cloud_workspace = CloudWorkspace(workspace_id='19d7a891-8e0e-40ac-8a8c-5faf8d11e47c', client_id=<SecretString: ****>, client_secret=<SecretString: ****>, api_root='https://api.airbyte.com/v1')
deployable_dummy_source = <airbyte.sources.base.Source object at 0x7f4d6a0f22c0>
deployable_dummy_destination = <airbyte.destinations.base.Destination object at 0x7f4d6a0f3370>
def test_deploy_connection(
cloud_workspace: CloudWorkspace,
deployable_dummy_source: ab.Source,
deployable_dummy_destination: ab.Destination,
) -> None:
"""Test deploying a source and cache to a workspace as a new connection."""
stream_names = deployable_dummy_source.get_selected_streams()
cloud_source = cloud_workspace.deploy_source(
name="test-source",
source=deployable_dummy_source,
random_name_suffix=True,
)
> cloud_destination = cloud_workspace.deploy_destination(
name="test-destination",
destination=deployable_dummy_destination,
random_name_suffix=True,
)
tests/integration_tests/cloud/test_cloud_workspaces.py:75:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
airbyte/cloud/workspaces.py:223: in deploy_destination
existing = self.list_destinations(name=name)
airbyte/cloud/workspaces.py:437: in list_destinations
destinations = api_util.list_destinations(
airbyte/_util/api_util.py:306: in list_destinations
response = airbyte_instance.destinations.list_destinations(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <airbyte_api.destinations.Destinations object at 0x7f4d6a0f2380>
request = ListDestinationsRequest(include_deleted=False, limit=100, offset=300, workspace_ids=['19d7a891-8e0e-40ac-8a8c-5faf8d11e47c'])
def list_destinations(self, request: api.ListDestinationsRequest) -> api.ListDestinationsResponse:
r"""List destinations"""
hook_ctx = HookContext(operation_id='listDestinations', oauth2_scopes=[], security_source=self.sdk_configuration.security)
base_url = utils.template_url(*self.sdk_configuration.get_server_details())
url = base_url + '/destinations'
if callable(self.sdk_configuration.security):
headers, query_params = utils.get_security(self.sdk_configuration.security())
else:
headers, query_params = utils.get_security(self.sdk_configuration.security)
query_params = { **utils.get_query_params(request), **query_params }
headers['Accept'] = 'application/json'
headers['user-agent'] = self.sdk_configuration.user_agent
client = self.sdk_configuration.client
try:
req = client.prepare_request(requests_http.Request('GET', url, params=query_params, headers=headers))
req = self.sdk_configuration.get_hooks().before_request(BeforeRequestContext(hook_ctx), req)
http_res = client.send(req)
except Exception as e:
_, e = self.sdk_configuration.get_hooks().after_error(AfterErrorContext(hook_ctx), None, e)
if e is not None:
raise e
if utils.match_status_codes(['403','404','4XX','5XX'], http_res.status_code):
result, e = self.sdk_configuration.get_hooks().after_error(AfterErrorContext(hook_ctx), http_res, None)
if e is not None:
raise e
if result is not None:
http_res = result
else:
http_res = self.sdk_configuration.get_hooks().after_success(AfterSuccessContext(hook_ctx), http_res)
res = api.ListDestinationsResponse(status_code=http_res.status_code, content_type=http_res.headers.get('Content-Type') or '', raw_response=http_res)
if http_res.status_code == 200:
# pylint: disable=no-else-return
if utils.match_content_type(http_res.headers.get('Content-Type') or '', 'application/json'):
out = utils.unmarshal_json(http_res.text, Optional[models.DestinationsResponse])
res.destinations_response = out
else:
content_type = http_res.headers.get('Content-Type')
raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
elif http_res.status_code == 403 or http_res.status_code == 404 or http_res.status_code >= 400 and http_res.status_code < 500 or http_res.status_code >= 500 and http_res.status_code < 600:
> raise errors.SDKError('API error occurred', http_res.status_code, http_res.text, http_res)
E airbyte_api.errors.sdkerror.SDKError: API error occurred: Status 500
E {"status":500,"type":"https://reference.airbyte.com/reference/errors","title":"unexpected-problem","detail":"An unexpected problem has occurred. If this is an error that needs to be addressed, please submit a pull request or github issue.","documentationUrl":null,"data":{"message":"Secret reference 9841a64b-e357-45e3-ac47-b0f5e1382308 does not exist but is referenced in the config"}}
.venv/lib/python3.10/site-packages/airbyte_api/destinations.py:229: SDKError
Loading