diff --git a/.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml b/.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml index 03277efec18f..368de62744b1 100644 --- a/.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml +++ b/.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml @@ -95,10 +95,9 @@ jobs: matrix: job_name: [beam_PostCommit_Python_Nexmark_Direct] # Query numbers are listed explicitly due to issues with Python Nexmark Query: - # query = 1 - https://github.com/apache/beam/issues/24678 # query = 4,6,9 - https://github.com/apache/beam/issues/24679 # query = 12 - https://github.com/apache/beam/issues/24680 - query: [0, 2, 3, 5, 7, 8, 10, 11] + query: [0, 1, 2, 3, 5, 7, 8, 10, 11] if: | github.event_name == 'workflow_dispatch' || github.event_name == 'pull_request' || diff --git a/sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query1.py b/sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query1.py index 5588bc3cb1eb..315b333c080f 100644 --- a/sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query1.py +++ b/sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query1.py @@ -29,8 +29,6 @@ from apache_beam.testing.benchmarks.nexmark.models import nexmark_model from apache_beam.testing.benchmarks.nexmark.queries import nexmark_query_util -USD_TO_EURO = 0.89 - def load(events, metadata=None, pipeline_options=None): return ( @@ -38,5 +36,5 @@ def load(events, metadata=None, pipeline_options=None): | nexmark_query_util.JustBids() | 'ConvertToEuro' >> beam.Map( lambda bid: nexmark_model.Bid( - bid.auction, bid.bidder, bid.price * USD_TO_EURO, bid.date_time, - bid.extra))) + bid.auction, bid.bidder, + (bid.price * 89) // 100, bid.date_time, bid.extra)))