This is an automated email from the ASF dual-hosted git repository.
fcsaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git
The following commit(s) were added to refs/heads/main by this push:
new 7cfbe5e [hotfix] Turn back Python CI
7cfbe5e is described below
commit 7cfbe5e7be3bb18e4e21179d28e5487697bddc16
Author: Ferenc Csaky <[email protected]>
AuthorDate: Tue Jan 20 18:10:23 2026 +0100
[hotfix] Turn back Python CI
---
.github/workflows/nightly.yml | 8 ++++++++
.github/workflows/push_pr.yml | 9 ++++++++-
flink-python/setup.py | 22 ++++++++++++++++------
flink-python/tox.ini | 2 +-
4 files changed, 33 insertions(+), 8 deletions(-)
diff --git a/.github/workflows/nightly.yml b/.github/workflows/nightly.yml
index 9c13990..ea49368 100644
--- a/.github/workflows/nightly.yml
+++ b/.github/workflows/nightly.yml
@@ -34,3 +34,11 @@ jobs:
flink_url: https://s3.amazonaws.com/flink-nightly/flink-${{ matrix.flink
}}-bin-scala_2.12.tgz
cache_flink_binary: false
secrets: inherit
+
+ python_test:
+ strategy:
+ matrix:
+ flink: [2.0-SNAPSHOT]
+ uses:
apache/flink-connector-shared-utils/.github/workflows/python_ci.yml@ci_utils
+ with:
+ flink_version: ${{ matrix.flink }}
diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index 625e50b..8e20e86 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -23,11 +23,11 @@ concurrency:
cancel-in-progress: true
jobs:
compile_and_test:
- uses: ./.github/workflows/common.yml
strategy:
matrix:
flink: [2.0.0]
java: ['11, 17, 21']
+ uses: ./.github/workflows/common.yml
with:
flink_version: ${{ matrix.flink }}
jdk_version: ${{ matrix.java }}
@@ -35,3 +35,10 @@ jobs:
cache_flink_binary: true
secrets: inherit
+ python_test:
+ strategy:
+ matrix:
+ flink: [2.0.0]
+ uses:
apache/flink-connector-shared-utils/.github/workflows/python_ci.yml@ci_utils
+ with:
+ flink_version: ${{ matrix.flink }}
diff --git a/flink-python/setup.py b/flink-python/setup.py
index f6cfaf8..5a46ef3 100644
--- a/flink-python/setup.py
+++ b/flink-python/setup.py
@@ -79,7 +79,17 @@ def prepare_pyflink_dir():
connector_version = pom_root.findall(
"./{http://maven.apache.org/POM/4.0.0}version";)[0].text.replace("-SNAPSHOT",
".dev0")
- flink_dependency = "apache-flink>=" + flink_version
+ # Pin to the minor version (e.g., >=1.19.1,<1.20.0) to allow patch updates
+ # but prevent major/minor version upgrades
+ version_parts = flink_version.split('.')
+ if len(version_parts) >= 2:
+ next_minor = str(int(version_parts[1]) + 1)
+ next_version = version_parts[0] + '.' + next_minor + '.0'
+ flink_dependency = "apache-flink>=" + flink_version + ",<" +
next_version
+ else:
+ # Fallback to exact match if version format is unexpected
+ print("Falling back to exact match for unexpected version format: " +
flink_version)
+ flink_dependency = "apache-flink==" + flink_version
with io.open(VERSION_FILE, 'w', encoding='utf-8') as f:
f.write('# Generated file, do not edit\n')
@@ -94,8 +104,8 @@ def prepare_pyflink_dir():
print("Python version used to package: " + sys.version)
# Python version check
-if sys.version_info < (3, 7):
- print("Python versions prior to 3.7 are not supported for PyFlink.",
+if sys.version_info < (3, 8):
+ print("Python versions prior to 3.8 are not supported for PyFlink.",
file=sys.stderr)
sys.exit(-1)
@@ -132,7 +142,7 @@ setup(
license='https://www.apache.org/licenses/LICENSE-2.0',
author='Apache Software Foundation',
author_email='[email protected]',
- python_requires='>=3.7',
+ python_requires='>=3.8',
install_requires=[flink_dependency],
description='Apache Flink Python AWS Connector API',
long_description=long_description,
@@ -144,10 +154,10 @@ setup(
classifiers=[
'Development Status :: 5 - Production/Stable',
'License :: OSI Approved :: Apache Software License',
- 'Programming Language :: Python :: 3.7',
'Programming Language :: Python :: 3.8',
'Programming Language :: Python :: 3.9',
- 'Programming Language :: Python :: 3.10']
+ 'Programming Language :: Python :: 3.10',
+ 'Programming Language :: Python :: 3.11']
)
print("\nFlink AWS connector package is ready\n")
diff --git a/flink-python/tox.ini b/flink-python/tox.ini
index c21c00f..1f526fd 100644
--- a/flink-python/tox.ini
+++ b/flink-python/tox.ini
@@ -21,7 +21,7 @@
# in multiple virtualenvs. This configuration file will run the
# test suite on all supported python versions.
# new environments will be excluded by default unless explicitly added to
envlist.
-envlist = {py38, py39, py310}-cython
+envlist = {py39, py310, py311}-cython
[testenv]
whitelist_externals = /bin/bash
