diff --git a/target_postgres/db_sync.py b/target_postgres/db_sync.py index 4fba051..3bfcf2c 100644 --- a/target_postgres/db_sync.py +++ b/target_postgres/db_sync.py @@ -150,7 +150,7 @@ def record_to_csv_line(self, record): flatten = flatten_record(record) return ','.join( [ - json.dumps(flatten[name]) if name in flatten and flatten[name] else '' + json.dumps(flatten[name]) if name in flatten and (flatten[name] == 0 or flatten[name]) else '' for name in self.flatten_schema ] )