This is an automated email from the ASF dual-hosted git repository.
Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new ebe23f396c1 [Python] Keep Nexmark Query 1 bid prices as integers
(#40548)
ebe23f396c1 is described below
commit ebe23f396c186adf0033592ead54c832413a5288
Author: raams95 <[email protected]>
AuthorDate: Thu Oct 15 08:36:18 2026 -0500
[Python] Keep Nexmark Query 1 bid prices as integers (#40548)
---
.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml | 3 +--
.../python/apache_beam/testing/benchmarks/nexmark/queries/query1.py | 6 ++----
2 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml
b/.github/workflows/beam_PostCommit_Python_Nexmark_Direct.yml
index 03277efec18..368de62744b 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 5588bc3cb1e..315b333c080 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 @@ import apache_beam as beam
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)))
