fix misrename, and also rename DDProcessor to DDWorker

Author: robtandy

k8s/cluster.yaml

@@ -55,11 +55,11 @@ spec:
         - name: dd-proxy
           image: registry.ddbuild.io/dd-amd64:2025-06-17-b
           env:
-            - name: dd_WORKER_DEPLOYMENT
+            - name: DD_WORKER_DEPLOYMENT
               value: deployment-dd-worker
-            - name: dd_WORKER_DEPLOYMENT_PORT
+            - name: DD_WORKER_DEPLOYMENT_PORT
               value: "20201"
-            - name: dd_WORKER_DEPLOYMENT_NAMESPACE
+            - name: DD_WORKER_DEPLOYMENT_NAMESPACE
               valueFrom:
                 fieldRef:
                   fieldPath: metadata.namespace

k8s/dev_cluster.yaml

@@ -34,11 +34,11 @@ spec:
         - name: dd-proxy
           image: registry.ddbuild.io/dd:2025-06-16-e
           env:
-            - name: dd_WORKER_DEPLOYMENT
+            - name: DD_WORKER_DEPLOYMENT
               value: deployment-dd-worker
-            - name: dd_WORKER_DEPLOYMENT_PORT
+            - name: DD_WORKER_DEPLOYMENT_PORT
               value: "20201"
-            - name: dd_WORKER_DEPLOYMENT_NAMESPACE
+            - name: DD_WORKER_DEPLOYMENT_NAMESPACE
               valueFrom:
                 fieldRef:
                   fieldPath: metadata.namespace

src/lib.rs

@@ -32,7 +32,6 @@ pub mod logging;
 pub mod max_rows;
 pub mod physical;
 pub mod planning;
-pub mod processor_service;
 pub mod proxy_service;
 pub mod query_planner;
 pub mod record_batch_exec;
@@ -42,6 +41,7 @@ pub mod stage_reader;
 pub mod util;
 pub mod vocab;
 pub mod worker_discovery;
+pub mod worker_service;
 
 #[cfg(not(target_env = "msvc"))]
 use tikv_jemallocator::Jemalloc;

src/main.rs

@@ -1,8 +1,8 @@
 use anyhow::Result;
 use clap::Parser;
 use distributed_datafusion::{
-    friendly::new_friendly_name, processor_service::DDProcessorService,
-    proxy_service::DDProxyService, setup,
+    friendly::new_friendly_name, proxy_service::DDProxyService, setup,
+    worker_service::DDWorkerService,
 };
 
 #[derive(Parser)]
@@ -37,7 +37,7 @@ async fn main() -> Result<()> {
             service.serve().await?;
         }
         "worker" => {
-            let service = DDProcessorService::new(new_friendly_name()?, args.port).await?;
+            let service = DDWorkerService::new(new_friendly_name()?, args.port).await?;
             service.serve().await?;
         }
         _ => {