Prototype BigQuery CDC -> Anomaly detection python flex template.

.github/workflows/bqmonitor-pr.yml

@@ -0,0 +1,113 @@
+# Copyright 2026 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+name: BigQuery Anomaly Detection PR
+
+on:
+  pull_request:
+    branches:
+      - 'main'
+    paths:
+      - 'python/src/main/python/bigquery-anomaly-detection/**'
+      - 'python/src/test/python/bigquery-anomaly-detection/**'
+      - 'python/src/main/java/**/BigQueryAnomalyDetection*.java'
+      - 'python/src/test/java/**/BigQueryAnomalyDetection*.java'
+      - '.github/workflows/bqmonitor-pr.yml'
+  workflow_dispatch:
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
+env:
+  MAVEN_OPTS: -Dorg.slf4j.simpleLogger.log.org.apache.maven.plugins.shade=error
+  IT_REGION: us-west2
+
+permissions:
+  actions: write
+  checks: write
+  contents: read
+  pull-requests: read
+  statuses: write
+
+jobs:
+  python_unit_tests:
+    name: Python Unit Tests
+    timeout-minutes: 15
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: '3.11'
+      - name: Install dependencies and run tests
+        working-directory: python
+        run: |
+          pip install -r src/test/python/bigquery-anomaly-detection/requirements-test.txt
+          pip install -e src/main/python/bigquery-anomaly-detection
+          python -m unittest discover \
+            -s src/test/python/bigquery-anomaly-detection \
+            -p '*_test.py' \
+            -v
+  java_build:
+    name: Build
+    timeout-minutes: 60
+    runs-on: [self-hosted, it]
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
+      - name: Setup Environment
+        id: setup-env
+        uses: ./.github/actions/setup-env
+      - name: Run Build
+        run: |
+          ./cicd/run-build \
+          --modules-to-build="YAML"
+      - name: Cleanup Java Environment
+        uses: ./.github/actions/cleanup-java-env
+  java_integration_tests:
+    name: Integration Tests
+    needs: [python_unit_tests, java_build]
+    timeout-minutes: 120
+    runs-on: [self-hosted, it]
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
+      - name: Setup Environment
+        id: setup-env
+        uses: ./.github/actions/setup-env
+      - name: Run Integration Tests
+        run: |
+          ./cicd/run-it-tests \
+          --modules-to-build="YAML" \
+          --it-region="${{ env.IT_REGION }}" \
+          --it-project="cloud-teleport-testing" \
+          --it-artifact-bucket="cloud-teleport-testing-it-gitactions" \
+          --it-private-connectivity="datastream-connect-2" \
+          --test="BigQueryAnomalyDetectionIT"
+      - name: Upload Integration Tests Report
+        uses: actions/upload-artifact@v6
+        if: always()
+        with:
+          name: surefire-integration-test-results
+          path: |
+            **/surefire-reports/TEST-*.xml
+            **/surefire-reports/*.html
+            **/surefire-reports/html/**
+          retention-days: 1
+      - name: Cleanup Java Environment
+        uses: ./.github/actions/cleanup-java-env
+        if: always()

@

@@ -0,0 +1,47 @@
+initial
+
+# Please enter the commit message for your changes. Lines starting
+# with '#' will be ignored, and an empty message aborts the commit.
+#
+# Date:      Mon Mar 9 09:12:57 2026 -0400
+#
+# On branch bqmonitor
+# Your branch is up to date with 'origin/bqmonitor'.
+#
+# Changes to be committed:
+#	modified:   plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/DockerfileGenerator.java
+#	modified:   plugins/core-plugin/src/main/resources/Dockerfile-template-python
+#	modified:   plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/DockerfileGeneratorTest.java
+#	modified:   plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java
+#	new file:   python/README_BigQuery_Anomaly_Detection.md
+#	new file:   python/default_base_bqmonitor_requirements.txt
+#	modified:   python/generate_all_dependencies.sh
+#	new file:   python/src/main/java/com/google/cloud/teleport/templates/python/BigQueryAnomalyDetection.java
+#	new file:   python/src/main/python/bigquery-anomaly-detection/main.py
+#	new file:   python/src/main/python/bigquery-anomaly-detection/pyproject.toml
+#	new file:   python/src/main/python/bigquery-anomaly-detection/requirements.txt
+#	new file:   python/src/main/python/bigquery-anomaly-detection/setup.py
+#	new file:   python/src/main/python/bigquery-anomaly-detection/src/bqmonitor/__init__.py
+#	new file:   python/src/main/python/bigquery-anomaly-detection/src/bqmonitor/cdc.py
+#	new file:   python/src/main/python/bigquery-anomaly-detection/src/bqmonitor/metric.py
+#	new file:   python/src/main/python/bigquery-anomaly-detection/src/bqmonitor/pipeline.py
+#	new file:   python/src/main/python/bigquery-anomaly-detection/src/bqmonitor/safe_eval.py
+#	modified:   python/src/main/python/job-builder-server/requirements.txt
+#	modified:   python/src/main/python/streaming-llm/requirements.txt
+#	modified:   python/src/main/python/word-count-python/requirements.txt
+#	modified:   python/src/main/python/yaml-template/requirements.txt
+#	new file:   python/src/test/java/com/google/cloud/teleport/templates/python/BigQueryAnomalyDetectionIT.java
+#	modified:   v2/googlecloud-and-mongodb/src/main/resources/requirements.txt
+#	modified:   v2/googlecloud-to-elasticsearch/src/main/resources/requirements.txt
+#	modified:   v2/googlecloud-to-googlecloud/src/main/resources/requirements.txt
+#	modified:   v2/googlecloud-to-splunk/src/main/resources/requirements.txt
+#	modified:   v2/pubsub-binary-to-bigquery/src/main/resources/requirements.txt
+#	modified:   yaml/src/main/python/requirements.txt
+#
+# Untracked files:
+#	diff.txt
+#	launcher_logs.txt
+#	v1/logs.txt
+#	v1/src/main/java/com/google/cloud/teleport/templates/unwrap-hec-payload.js
+#	yaml/src/test/python/logs.txt
+#