From 03ac8131e03f16a74ee204aa6cf51fc83c478004 Mon Sep 17 00:00:00 2001 From: Akarys Shorabek Date: Tue, 1 Jul 2025 04:37:47 +0500 Subject: [PATCH 1/2] Fix PostCommit Python Xlang IO Direct --- .github/workflows/beam_PostCommit_Python_Xlang_IO_Direct.yml | 2 +- sdks/python/apache_beam/transforms/managed_iceberg_it_test.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/.github/workflows/beam_PostCommit_Python_Xlang_IO_Direct.yml b/.github/workflows/beam_PostCommit_Python_Xlang_IO_Direct.yml index 35c250e8627b..c5781ee6a66d 100644 --- a/.github/workflows/beam_PostCommit_Python_Xlang_IO_Direct.yml +++ b/.github/workflows/beam_PostCommit_Python_Xlang_IO_Direct.yml @@ -17,7 +17,7 @@ name: PostCommit Python Xlang IO Direct on: schedule: - - cron: '30 5/6 * * *' + - cron: '30 4/6 * * *' pull_request_target: paths: ['release/trigger_all_tests.json', '.github/trigger_files/beam_PostCommit_Python_Xlang_IO_Direct.json'] workflow_dispatch: diff --git a/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py b/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py index 4d9790f2dd5c..c805e83e8780 100644 --- a/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py +++ b/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py @@ -16,7 +16,7 @@ # import os -import time +import uuid import unittest import pytest @@ -53,7 +53,7 @@ def _create_row(self, num: int): def test_write_read_pipeline(self): iceberg_config = { - "table": "test_iceberg_write_read.test_" + str(int(time.time())), + "table": "test_iceberg_write_read.test_" + uuid.uuid4().hex, "catalog_name": "default", "catalog_properties": { "type": "hadoop", From 24d5f3b50dc4e25e3c433ed8d2913ed2e38f7923 Mon Sep 17 00:00:00 2001 From: Akarys Shorabek Date: Tue, 1 Jul 2025 05:28:30 +0500 Subject: [PATCH 2/2] Fix formatting --- sdks/python/apache_beam/transforms/managed_iceberg_it_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py b/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py index c805e83e8780..b1e53a79bd41 100644 --- a/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py +++ b/sdks/python/apache_beam/transforms/managed_iceberg_it_test.py @@ -16,8 +16,8 @@ # import os -import uuid import unittest +import uuid import pytest