airbytehq / airbytehq/airbyte-api-python-sdk

when executing stream_details = s.streams.get_stream_properties(req)

未關閉
#63 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
Python
星號
61
分支
27
平均合併
4 分鐘
30 天內合併 PR
2

描述

line 697, in unmarshal_json
raise AttributeError(
AttributeError: unable to unmarshal

reproduce -
install latest airbyte helm.
setup GITHUB and Snowflake connection

run this code -

```
from airbyte import Airbyte
from airbyte.connections import shared
from airbyte.models import errors, operations, shared
from airbyte.models.operations import ListConnectionsRequest


import airbyte
from airbyte.models import shared

s = Airbyte(server_url="http://127.0.0.1:8006/v1",
security=shared.Security(
basic_auth=shared.SchemeBasicAuth(
password="",
username="",
),
),)
r = s.connections.list_connections(operations.ListConnectionsRequest())
for connection_id in r.raw_response.json()['data']:
print(connection_id['connectionId'])
cr = s.connections.get_connection(operations.GetConnectionRequest(connection_id['connectionId']))
req = operations.GetStreamPropertiesRequest(
destination_id=cr.raw_response.json()['destinationId'],
source_id=cr.raw_response.json()['sourceId'],
ignore_cache=True,
)

stream_details = s.streams.get_stream_properties(req)

```

貢獻指南

開啟貢獻指南

評估

這個 Issue 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。