ref: Remove is_taskworker_only_project gating (#594)

Co-authored-by: Claude <noreply@anthropic.com>

Author: NicoHinderling

src/launchpad/config.py

@@ -24,7 +24,6 @@
 from sentry_kafka_schemas import get_codec
 
 from launchpad.artifact_processor import ArtifactProcessor
-from launchpad.config import is_taskworker_only_project
 from launchpad.constants import PREPROD_ARTIFACT_EVENTS_TOPIC
 from launchpad.tracing import RequestLogFilter
 from launchpad.utils.arroyo_metrics import DatadogMetricsBackend
@@ -94,11 +93,6 @@ def process_kafka_message_with_service(
         raise
 
     artifact_id = decoded.get("artifact_id", "unknown")
-    project_id = str(decoded.get("project_id", ""))
-
-    if is_taskworker_only_project(project_id):
-        logger.info("Skipping Kafka processing for project %s (taskworker-only)", project_id)
-        return None  # type: ignore[return-value]
 
     # Spawn actual processing in a subprocess
     process = multiprocessing.Process(target=_process_in_subprocess, args=(decoded, log_queue))

src/launchpad/kafka.py

@@ -1,5 +1,4 @@
 from launchpad.artifact_processor import ArtifactProcessor
-from launchpad.config import is_taskworker_only_project
 from launchpad.utils.logging import get_logger, setup_logging
 
 from .app import app
@@ -14,8 +13,5 @@ def process_artifact(artifact_id: str, project_id: str, organization_id: str) ->
     setup_logging()
     logger.info(f"Processing artifact {artifact_id}")
     logger.info(f"Params: artifact_id={artifact_id}, project_id={project_id}, organization_id={organization_id}")
-    if not is_taskworker_only_project(str(project_id)):
-        logger.info("Skipping TaskWorker processing for project %s (not in taskworker-only list)", project_id)
-        return
     ArtifactProcessor.process_message(artifact_id, project_id, organization_id)
     logger.info(f"Processed artifact {artifact_id}")