(beam) branch master updated: Add States for Pause (#37546)

[damccorm]

This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 25d3a2e46bf Add States for Pause (#37546)
25d3a2e46bf is described below

commit 25d3a2e46bfeadd4841eb731420a73dd982af701
Author: Tarun Annapareddy <tannapare...@google.com>
AuthorDate: Mon Feb 9 11:19:53 2026 -0800

    Add States for Pause (#37546)
---
 .../main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java | 2 ++
 .../java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java  | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
index a7dd5155b66..0237923e4e4 100644
--- 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
+++ 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java
@@ -212,6 +212,7 @@ public class MonitoringUtil {
       case "JOB_STATE_UNKNOWN":
         return State.UNKNOWN;
       case "JOB_STATE_STOPPED":
+      case "JOB_STATE_PAUSED": // Job is paused; the closest mapping is STOPPED
         return State.STOPPED;
       case "JOB_STATE_FAILED":
         return State.FAILED;
@@ -224,6 +225,7 @@ public class MonitoringUtil {
       case "JOB_STATE_PENDING": // Job has not yet started; closest mapping is 
RUNNING
       case "JOB_STATE_DRAINING": // Job is still active; the closest mapping 
is RUNNING
       case "JOB_STATE_CANCELLING": // Job is still active; the closest mapping 
is RUNNING
+      case "JOB_STATE_PAUSING": // Job is still active; the closest mapping is 
RUNNING
       case "JOB_STATE_RESOURCE_CLEANING_UP": // Job is still active; the 
closest mapping is RUNNING
         return State.RUNNING;
 
diff --git 
a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java
 
b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java
index df169b66a58..5f76b6750ff 100644
--- 
a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java
+++ 
b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/util/MonitoringUtilTest.java
@@ -99,7 +99,9 @@ public class MonitoringUtilTest {
     assertEquals(State.UPDATED, MonitoringUtil.toState("JOB_STATE_UPDATED"));
 
     // Non-trivially mapped cases
+    assertEquals(State.STOPPED, MonitoringUtil.toState("JOB_STATE_PAUSED"));
     assertEquals(State.RUNNING, MonitoringUtil.toState("JOB_STATE_DRAINING"));
+    assertEquals(State.RUNNING, MonitoringUtil.toState("JOB_STATE_PAUSING"));
     assertEquals(State.DONE, MonitoringUtil.toState("JOB_STATE_DRAINED"));
   }