diff --git a/airbyte/destinations/base.py b/airbyte/destinations/base.py index b1482bc0..8593dac2 100644 --- a/airbyte/destinations/base.py +++ b/airbyte/destinations/base.py @@ -265,7 +265,7 @@ def _write_airbyte_message_stream( with as_temp_files( files_contents=[ self._hydrated_config, - catalog_provider.configured_catalog.model_dump_json(), + catalog_provider.configured_catalog.model_dump_json(exclude_none=True), ] ) as [ config_file, diff --git a/airbyte/sources/base.py b/airbyte/sources/base.py index 698a50d9..20f05de8 100644 --- a/airbyte/sources/base.py +++ b/airbyte/sources/base.py @@ -752,7 +752,7 @@ def _read_with_catalog( with as_temp_files( [ self._hydrated_config, - catalog.model_dump_json(), + catalog.model_dump_json(exclude_none=True), state.to_state_input_file_text() if state else "[]", ] ) as [