This is an automated email from the ASF dual-hosted git repository. fcsaky pushed a commit to branch v6.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git
commit bc1b4699edd761c5096b5a17221d8429dc13d6ff 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
