ref(processor): Decouple ArtifactProcessor from Kafka message schema

[NicoHinderling]

Summary

Decouples ArtifactProcessor.process_message() from the Kafka message schema (PreprodArtifactEvents dict) by changing its signature to accept individual parameters (artifact_id, project_id, organization_id, requested_features).

This is prep work for the upcoming TaskWorker mode, which calls process_message() directly without a Kafka message envelope. By making the interface explicit, ArtifactProcessor becomes reusable by both the Kafka consumer and the TaskWorker.

Changes

• artifact_processor.py: Replace dict parameter with explicit kwargs. Remove sentry_kafka_schemas import. Add features param to process_artifact(). Minor cleanups (Dict → dict, raise e → raise, simplify _guess_message).
• kafka.py: Update _process_in_subprocess to call new signature with keyword args.
• requirements-dev.txt: Bump sentry-protos from ==0.2.0 to >=0.4.11.
• Tests: Update all process_message call sites in unit and integration tests.

Test plan

• make check passes (lint, format, types)
• make test-unit passes
• make test-integration passes

[NicoHinderling]

• feat(taskworker): Attempt to add healthcheck logic #583
• feat(worker): Add TaskWorker mode for TaskBroker RPC #582
• ref(processor): Decouple ArtifactProcessor from Kafka message schema #581 👈 (View in Graphite)
• main

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

[sentry]

Sentry Build Distribution

App Name	App ID	Version	Configuration	Install Page
Hacker News	com.emergetools.hackernews	1.0.2 (13)	Release	Install Build

[NicoHinderling]

minor cleanup

[cursor]

Cursor Bugbot has reviewed your changes and found 1 potential issue.

^{Bugbot Autofix is OFF. To automatically fix reported issues with cloud agents, enable autofix in the Cursor dashboard.}