feat: implement NdviIndicator.submit_batch() for openEO batch jobs

Generated with [Claude Code](https://claude.ai/code)
via [Happy](https://happy.engineering)

Co-Authored-By: Claude <noreply@anthropic.com>
Co-Authored-By: Happy <yesreply@happy.engineering>

app/indicators/ndvi.py

@@ -25,7 +25,7 @@ from app.models import (
     TrendDirection,
     ConfidenceLevel,
 )
-from app.openeo_client import get_connection, build_ndvi_graph, build_true_color_graph, _bbox_dict
+from app.openeo_client import get_connection, build_ndvi_graph, build_true_color_graph, _bbox_dict, submit_as_batch
 
 logger = logging.getLogger(__name__)
 
@@ -40,6 +40,49 @@ class NdviIndicator(BaseIndicator):
     estimated_minutes = 8
 
     _true_color_path: str | None = None
+    uses_batch = True
+
+    async def submit_batch(
+        self, aoi: AOI, time_range: TimeRange, season_months: list[int] | None = None
+    ) -> list:
+        conn = get_connection()
+        bbox = _bbox_dict(aoi.bbox)
+
+        current_start = time_range.start.isoformat()
+        current_end = time_range.end.isoformat()
+
+        baseline_start = date(
+            time_range.start.year - BASELINE_YEARS,
+            time_range.start.month,
+            time_range.start.day,
+        ).isoformat()
+        baseline_end = date(
+            time_range.start.year,
+            time_range.start.month,
+            time_range.start.day,
+        ).isoformat()
+
+        current_cube = build_ndvi_graph(
+            conn=conn, bbox=bbox,
+            temporal_extent=[current_start, current_end],
+            resolution_m=RESOLUTION_M,
+        )
+        baseline_cube = build_ndvi_graph(
+            conn=conn, bbox=bbox,
+            temporal_extent=[baseline_start, baseline_end],
+            resolution_m=RESOLUTION_M,
+        )
+        true_color_cube = build_true_color_graph(
+            conn=conn, bbox=bbox,
+            temporal_extent=[current_start, current_end],
+            resolution_m=RESOLUTION_M,
+        )
+
+        return [
+            submit_as_batch(conn, current_cube, f"ndvi-current-{aoi.name}"),
+            submit_as_batch(conn, baseline_cube, f"ndvi-baseline-{aoi.name}"),
+            submit_as_batch(conn, true_color_cube, f"ndvi-truecolor-{aoi.name}"),
+        ]
 
     async def process(
         self, aoi: AOI, time_range: TimeRange, season_months: list[int] | None = None

tests/test_indicator_ndvi.py

@@ -125,3 +125,29 @@ def test_ndvi_compute_stats():
     assert 0 < stats["overall_mean"] < 1
     assert "valid_months" in stats
     assert stats["valid_months"] == 12
+
+
+@pytest.mark.asyncio
+async def test_ndvi_submit_batch_creates_three_jobs(test_aoi, test_time_range):
+    """submit_batch() creates current, baseline, and true-color batch jobs."""
+    from app.indicators.ndvi import NdviIndicator
+
+    indicator = NdviIndicator()
+
+    mock_conn = MagicMock()
+    mock_job = MagicMock()
+    mock_job.job_id = "j-test"
+    mock_conn.create_job.return_value = mock_job
+
+    with patch("app.indicators.ndvi.get_connection", return_value=mock_conn), \
+         patch("app.indicators.ndvi.build_ndvi_graph") as mock_ndvi_graph, \
+         patch("app.indicators.ndvi.build_true_color_graph") as mock_tc_graph:
+
+        mock_ndvi_graph.return_value = MagicMock()
+        mock_tc_graph.return_value = MagicMock()
+
+        jobs = await indicator.submit_batch(test_aoi, test_time_range)
+
+    assert len(jobs) == 3
+    assert mock_ndvi_graph.call_count == 2  # current + baseline
+    assert mock_tc_graph.call_count == 1    # true-color