Skip to content

[Sync] Migrate signals to product events - #3657

Merged
Herklos merged 1 commit into
devfrom
fix/signal-publish
Aug 26, 2026
Merged

[Sync] Migrate signals to product events#3657
Herklos merged 1 commit into
devfrom
fix/signal-publish

Conversation

@Herklos

@Herklos Herklos commented Aug 24, 2026

Copy link
Copy Markdown
Contributor

No description provided.

@Herklos
Herklos force-pushed the fix/signal-publish branch 7 times, most recently from 1879b42 to db0330d Compare August 25, 2026 08:06
@Herklos
Herklos marked this pull request as ready for review August 25, 2026 08:07
@Herklos
Herklos requested a review from GuillaumeDSM as a code owner August 25, 2026 08:07

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

👍 can we move this file to the functional_tests dir plz ? (it's not a unit tests file)

Comment thread packages/sync/octobot_sync/artifacts.py Outdated
Comment on lines +149 to +160
try:
result = await session.content_client.pull(layout.keyring_pull(space_id))
except starfish_sdk.types.StarfishHttpError:
return None
keyring = starfish_keyring.Keyring.from_dict(result.data)
try:
return starfish_keyring.create_keyring_encryptor(
keyring, session.keys["kemPub"], session.keys["kemPriv"], trusted_adders=trusted_adders
)
except ValueError as encryptor_error:
_logger().debug(f"Could not build the artifact keyring encryptor: {encryptor_error}")
return None

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

is it ok here to silence those exceptions?

Comment thread packages/sync/octobot_sync/artifacts.py Outdated
Comment on lines +209 to +212
_logger().debug(
f"Could not open artifact keyring for space {space_id!r}: {encryptor_error}"
)
return []

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

same here, should we just log debug and continue instead of leaving it to the caller to chose to raise or not?

_get_identity(context)
)
plaintext = debug_state.to_json()
case enums.TemporaryCollections.TEMP_PRODUCT_SIGNALS.value:

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

👍

@Herklos
Herklos force-pushed the fix/signal-publish branch from db0330d to d0d5b13 Compare August 25, 2026 12:18
@Herklos

Herklos commented Aug 25, 2026

Copy link
Copy Markdown
Contributor Author

it's up

@Herklos
Herklos requested a review from GuillaumeDSM August 26, 2026 06:36
@Herklos Herklos self-assigned this Aug 26, 2026

@GuillaumeDSM GuillaumeDSM left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

👍

Comment on lines +154 to +155
if pull_error.status == 404:
return None

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

👍

@Herklos
Herklos merged commit 668ca1c into dev Aug 26, 2026
23 checks passed
@Herklos
Herklos deleted the fix/signal-publish branch August 26, 2026 08:46
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.

2 participants