Skip to content
Draft
Changes from 2 commits
Commits
Show all changes
25 commits
Select commit Hold shift + click to select a range
4e24489
spike: Replace null namespaces with empty strings
devin-ai-integration[bot] Aug 13, 2025
054093a
fix: Shorten comment to resolve Ruff lint error (line length)
devin-ai-integration[bot] Aug 13, 2025
0c2f196
Update airbyte/_message_iterators.py
aaronsteers Aug 13, 2025
5c05e1d
Update airbyte/_message_iterators.py
aaronsteers Aug 13, 2025
761554e
fix: Replace null namespaces with empty strings in catalog validation
devin-ai-integration[bot] Aug 13, 2025
3a2cb45
fix: Also handle null source_defined_cursor and is_resumable fields
devin-ai-integration[bot] Aug 13, 2025
d098050
fix: Clean up null namespaces in record messages from external sources
devin-ai-integration[bot] Aug 13, 2025
201187a
fix: Clean up null namespaces in record messages from external source…
devin-ai-integration[bot] Aug 13, 2025
808ec52
fix: Clean up null namespaces in record messages at source execution …
devin-ai-integration[bot] Aug 13, 2025
9aad1fb
fix: Comment out performance-problematic namespace checks in high-vol…
devin-ai-integration[bot] Aug 13, 2025
85a3b4e
fix: Ensure catalog cleaning changes are included
devin-ai-integration[bot] Aug 13, 2025
4c5a6d2
fix: Use Pydantic exclude_none=True to omit null fields from catalog …
devin-ai-integration[bot] Aug 13, 2025
50b07ad
fix: Add exclude_none=True to remaining model_dump_json() calls
devin-ai-integration[bot] Aug 13, 2025
89ff68a
fix: Complete exclude_none=True implementation for all model_dump_jso…
devin-ai-integration[bot] Aug 13, 2025
9c4f594
fix: Clean up null namespaces in trace stream_status messages
devin-ai-integration[bot] Aug 13, 2025
82e7730
Apply suggestion from @aaronsteers
aaronsteers Aug 13, 2025
405b947
Apply suggestion from @aaronsteers
aaronsteers Aug 13, 2025
35d9d60
Apply suggestion from @aaronsteers
aaronsteers Aug 13, 2025
d0a6f24
Apply suggestion from @aaronsteers
aaronsteers Aug 13, 2025
a8205c4
Apply suggestion from @aaronsteers
aaronsteers Aug 13, 2025
c8d1d41
feat: Switch benchmark default from source-e2e-test to source-faker
devin-ai-integration[bot] Aug 13, 2025
c3dce14
fix: Simplify source-faker config to use only count and seed parameters
devin-ai-integration[bot] Aug 13, 2025
88756af
feat: Test catalog-only exclude_none theory, update get_benchmark_sou…
devin-ai-integration[bot] Aug 13, 2025
57c9863
fix: Address lint and type checking issues
devin-ai-integration[bot] Aug 13, 2025
dbb96d0
security: Replace insecure tempfile.mktemp() with secure tempfile.mks…
devin-ai-integration[bot] Aug 13, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions airbyte/_message_iterators.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@ def _new_stream_success_message(stream_name: str) -> AirbyteMessage:
stream_status=AirbyteStreamStatusTraceMessage(
stream_descriptor=StreamDescriptor(
name=stream_name,
namespace="", # Use empty string instead of None for compatibility
),
status=AirbyteStreamStatus.COMPLETE,
reasons=None,
Expand Down Expand Up @@ -108,9 +109,8 @@ def generator() -> Generator[AirbyteMessage, None, None]:
"datetime.datetime", record.get(AB_EXTRACTED_AT_COLUMN)
).timestamp()
),
# `meta` and `namespace` are not handled:
meta=None,
namespace=None,
namespace="", # Use empty string instead of None
),
)

Expand Down
Loading