Skip to content

Conversation

@edgao
Copy link
Contributor

@edgao edgao commented Oct 27, 2025

Important

Auto-merge enabled.

This PR is set to merge automatically when all requirements are met.

@edgao edgao requested a review from a team as a code owner October 27, 2025 20:15
@github-actions
Copy link
Contributor

👋 Greetings, Airbyte Team Member!

Here are some helpful tips and reminders for your convenience.

Helpful Resources

PR Slash Commands

Airbyte Maintainers (that's you!) can execute the following slash commands on your PR:

  • /format-fix - Fixes most formatting issues.
  • /bump-version - Bumps connector versions.
    • You can specify a custom changelog by passing changelog. Example: /bump-version changelog="My cool update"
    • Leaving the changelog arg blank will auto-populate the changelog from the PR title.
  • /run-cat-tests - Runs legacy CAT tests (Connector Acceptance Tests)
  • /build-connector-images - Builds and publishes a pre-release docker image for the modified connector(s).
  • JVM connectors:
    • /update-connector-cdk-version connector=<CONNECTOR_NAME> - Updates the specified connector to the latest CDK version.
      Example: /update-connector-cdk-version connector=destination-bigquery
    • /bump-bulk-cdk-version type=patch changelog='foo' - Bump the Bulk CDK's version. type can be major/minor/patch.
  • Python connectors:
    • /poe connector source-example lock - Run the Poe lock task on the source-example connector, committing the results back to the branch.
    • /poe source example lock - Alias for /poe connector source-example lock.
    • /poe source example use-cdk-branch my/branch - Pin the source-example CDK reference to the branch name specified.
    • /poe source example use-cdk-latest - Update the source-example CDK dependency to the latest available version.

📝 Edit this welcome message.

/** Log some information about why state messages cannot be flushed. */
// implementation-wise, this is largely just mirroring getNextComplete(),
// except it logs things instead of actually doing anything.
fun logStateInfo() {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can we log full state message as well?

Copy link
Contributor

@subodh1810 subodh1810 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Lets log the full state message that is not complete as well along with the destination stats.

# Conflicts:
#	airbyte-cdk/bulk/changelog.md
#	airbyte-cdk/bulk/version.properties
@edgao edgao enabled auto-merge (squash) October 28, 2025 17:26
@edgao edgao merged commit 348cbfc into master Oct 28, 2025
49 of 50 checks passed
@edgao edgao deleted the edgao/unflushed_states_logging branch October 28, 2025 18:03
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants