niall_woodward
09/16/2021, 9:10 PMprimary_keys = []
on a stream, which in the schema message is being emitted as "key_properties": null
, and breaking pipelinewise-target-snowflake
, which expects either no key or an empty list in this scenario. Some traces:
{
"type": "SCHEMA",
"stream": "relationship_strengths",
"schema": {
"properties": {
"internal_id": {
"type": [
"integer",
"null"
]
},
"external_id": {
"type": [
"integer",
"null"
]
},
"strength": {
"type": [
"number",
"null"
]
}
},
"type": "object"
},
"key_properties": null
}
target-snowflake | if len(stream_schema_message.get('key_properties', [])) > 0 else []
target-snowflake | TypeError: object of type 'NoneType' has no len()
I'm not sure if the problem here lies in my stream definition, the SDK, or the target. Any help would be gladly appreciated.