Skip to content

Commit

Permalink
Fix write disposition (#170)
Browse files Browse the repository at this point in the history
  • Loading branch information
jdddog committed Jun 26, 2023
1 parent b7ed3d3 commit 5019bbc
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -514,7 +514,6 @@ def bq_load_main_table(self, release: CrossrefEventsRelease, **kwargs):
table_id=release.bq_main_table_id,
schema_file_path=self.schema_file_path,
source_format=SourceFormat.NEWLINE_DELIMITED_JSON,
write_disposition=bigquery.WriteDisposition.WRITE_TRUNCATE,
ignore_unknown_values=True,
)
set_task_state(success, self.bq_load_main_table.__name__, release)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -264,7 +264,6 @@ def bq_load(self, releases: List[OpenCitationsRelease], **kwargs) -> None:
csv_quote_character='"',
csv_skip_leading_rows=1,
csv_allow_quoted_newlines=True,
write_disposition=bigquery.WriteDisposition.WRITE_APPEND,
ignore_unknown_values=True,
)
set_task_state(success, self.bq_load.__name__, release)
Expand Down

0 comments on commit 5019bbc

Please sign in to comment.