Destinations CDK: CatalogParser sets default namespace

[edgao]

• CatalogParser is now responsible for setting the default namespace on stream objects.
  • This entails a bunch of knock-on changes:
    • All the core async stuff now operates on the original (null) namespace
    • BufferEnqueue also needs to set the default namespace right before handing the message to the queue
    • AsyncStreamConsumer needs to set the default namespace when calling OnCloseFunction
  • I also took the opportunity to make defaultNamespace non-nullable.
• This allows destinations code to stop thinking about it (i.e. we can remove all our catalog.streams.each(stream.setNamespace) blocks)

closes https://github.com/airbytehq/airbyte-internal-issues/issues/2413

[vercel[bot]]

The latest updates on your projects. Learn more about Vercel for Git ↗︎

1 Ignored Deployment

Name	Status	Preview	Comments	Updated (UTC)
airbyte-docs	⬜️ Ignored (Inspect)	Visit Preview		Jun 10, 2024 4:13pm

[edgao]

• #38121 : 2 dependent PRs (#38075 , #39107 ) 👈
• #38770
• master

This stack of pull requests is managed by Graphite. Learn more about stacking.

Join @edgao and the rest of your teammates on Graphite

[edgao]

/publish-java-cdk

:clock2: https://github.com/airbytehq/airbyte/actions/runs/9452125686 :white_check_mark: Successfully published Java CDK version=0.37.0!