Skip to content
This repository has been archived by the owner on Sep 23, 2024. It is now read-only.

Commit

Permalink
Change log level (#90)
Browse files Browse the repository at this point in the history
  • Loading branch information
koszti authored Jul 23, 2020
1 parent 35e95e7 commit 38e173a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion target_snowflake/db_sync.py
Original file line number Diff line number Diff line change
Expand Up @@ -351,7 +351,7 @@ def record_primary_key_string(self, record):
try:
key_props = [str(flatten[p]) for p in self.stream_schema_message['key_properties']]
except Exception as exc:
self.logger.info("Cannot find {} primary key(s) in record: {}".format(self.stream_schema_message['key_properties'],
self.logger.error("Cannot find {} primary key(s) in record: {}".format(self.stream_schema_message['key_properties'],
flatten))
raise exc
return ','.join(key_props)
Expand Down

0 comments on commit 38e173a

Please sign in to comment.