Siba Prasad Nayak
04/04/2025, 10:19 AM- name: tap-snowflake
namespace: tap_snowflake
pip_url: ./connectors/tap-snowflake
executable: tap-snowflake
capabilities:
- state
- catalog
- discover
- about
- stream-maps
settings:
- name: account
kind: string
value: aigoiop-hq79023
description: The Snowflake account identifier.
- name: user
kind: string
value: udey
description: The Snowflake username.
- name: password
kind: string
value: ********
description: The Snowflake password.
sensitive: true
- name: database
kind: string
value: PARTHAN_DB
description: The Snowflake database name.
- name: warehouse
kind: string
value: COMPUTE_WH
description: The Snowflake warehouse name.
select:
- public-account.name
- name: target-salesforce
namespace: target_salesforce
pip_url: ./connectors/target-salesforce
executable: target-salesforce
capabilities:
- about
- stream-maps
#- schema-flattening
config:
username: udey@vcs.sandbox
password: ********
security_token: nanLbbN3lexEw70gK7tLrzP4s
api_type: sandbox
sobject: Employee__c
action: insert
stream_maps:
'*': # Stream from the tap
__alias__: Employee__c
mappings:
"name": "Name"
Somehow this "mappings" configuration is not working. Throwing error as
2025-04-04T10:11:29.098748Z [warning ] Received state is invalid, incremental state has not been updated
2025-04-04T10:11:29.163005Z [info ] Incremental state has been updated at 2025-04-04 10:11:29.162967+00:00.
2025-04-04T10:11:29.163935Z [info ] TypeError: unhashable type: 'dict' cmd_type=elb consumer=True job_name=dev:tap-snowflake-to-target-salesforce name=target-salesforce producer=False run_id=0f693284-543d-4331-8029-ac397f2c6d83 stdio=stderr string_id=target-salesforce
2025-04-04T10:11:29.182189Z [info ] 2025-04-04 15:41:28,998 | INFO | snowflake.connector.connection | Snowflake Connector for Python Version: 3.13.2, Python Version: 3.13.2, Platform: Windows-11-10.0.22631-SP0 cmd_type=elb consumer=False job_name=dev:tap-snowflake-to-target-salesforce name=tap-snowflake producer=True run_id=0f693284-543d-4331-8029-ac397f2c6d83 stdio=stderr string_id=tap-snowflake
2025-04-04T10:11:29.183433Z [info ] 2025-04-04 15:41:28,999 | INFO | snowflake.connector.connection | Connecting to GLOBAL Snowflake domain cmd_type=elb consumer=False job_name=dev:tap-snowflake-to-target-salesforce name=tap-snowflake producer=True run_id=0f693284-543d-4331-8029-ac397f2c6d83 stdio=stderr string_id=tap-snowflake
2025-04-04T10:11:29.184298Z [info ] 2025-04-04 15:41:28,999 | INFO | snowflake.connector.connection | This connection is in OCSP Fail Open Mode. TLS Certificates would be checked for validity and revocation status. Any other Certificate Revocation related exceptions or OCSP Responder failures would be disregarded in favor of connectivity. cmd_type=elb consumer=False job_name=dev:tap-snowflake-to-target-salesforce name=tap-snowflake producer=True run_id=0f693284-543d-4331-8029-ac397f2c6d83 stdio=stderr string_id=tap-snowflake
2025-04-04T10:11:29.241665Z [error ] Loader failed
2025-04-04T10:11:29.242795Z [error ] Block run completed. block_type=ExtractLoadBlocks err=RunnerError('Loader failed') exit_codes={<PluginType.LOADERS: 'loaders'>: 1} set_number=0 success=False
Need help fixing this problem? Visit <http://melta.no/> for troubleshooting steps, or to
join our friendly Slack community.
Run invocation could not be completed as block failed: Loader failed
(meltanoEnv) PS C:\Siba_\Work\POC_ConnectorFactory\Gerrit\Connector_Factory_Development\meltano-backend>
So I am trying to map name (From Snowflake) to Name (To Salesforce) field. [Camelcase].
TypeError: unhashable type: 'dict'
Did not get much examples on internet related to this "mappings".Reuben (Matatika)
04/04/2025, 10:26 AMmappings
is not valid here: https://meltano.slack.com/archives/C069CPBCVPV/p1743610351125759?thread_ts=1743609996.637779&cid=C069CPBCVPVReuben (Matatika)
04/04/2025, 10:27 AMstream_maps:
'*': # Stream from the tap
__alias__: Employee__c
Name: name # map `name` to `Name`
name: __NULL__ # remove `name`
https://sdk.meltano.com/en/latest/stream_maps.html#aliasing-properties