Skip to content

Commit 3b44c3a

Browse files
committed
Fix Mock Tests
1 parent e32ed12 commit 3b44c3a

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_iceberg_batch.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,5 +58,5 @@ pipeline:
5858
rest-metrics-reporting-enabled: "false"
5959

6060
# Expected:
61-
# - Row(customer_id='C1', shipment_date='2023-05-01', shipment_cost=150.0, customer_name='Alice', customer_email='[email protected]')
62-
# - Row(customer_id='C1', shipment_date='2023-05-10', shipment_cost=20.0, customer_name='Alice', customer_email='[email protected]')
61+
# Row(customer_id='C1', shipment_date='2023-05-01', shipment_cost=150.0, customer_name='Alice', customer_email='[email protected]')
62+
# Row(customer_id='C1', shipment_date='2023-05-10', shipment_cost=20.0, customer_name='Alice', customer_email='[email protected]')

sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_iceberg_streaming.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,5 +61,5 @@ pipeline:
6161
triggering_frequency_seconds: 30
6262

6363
# Expected:
64-
# - Row(customer_id='C1', shipment_date='2023-05-01', shipment_cost=150.0, customer_name='Alice', customer_email='[email protected]')
65-
# - Row(customer_id='C1', shipment_date='2023-05-10', shipment_cost=20.0, customer_name='Alice', customer_email='[email protected]')
64+
# Row(customer_id='C1', shipment_date='2023-05-01', shipment_cost=150.0, customer_name='Alice', customer_email='[email protected]')
65+
# Row(customer_id='C1', shipment_date='2023-05-10', shipment_cost=20.0, customer_name='Alice', customer_email='[email protected]')

sdks/python/apache_beam/yaml/extended_tests/databases/iceberg.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ pipelines:
7373
catalog_properties:
7474
type: hadoop
7575
warehouse: "{TEMP_DIR}"
76-
filter: "label = '11a'"
76+
filter: '"label" = ''11a'''
7777
keep:
7878
- label
7979
- rank

0 commit comments

Comments
 (0)