What happened?
@derrickaw
There is a problem when trying to assert with beamSchema
- type: AssertEqual
config:
elements:
- {key: 'row1',
# Use explicit map syntax to match the actual output
column_families: {
cf1: {
cq1: [
{ value: "value1", timestamp_micros: 5000 }
],
cq2: [
{ value: "value2", timestamp_micros: 1000 }
]
}
}
}
in yaml this is converted to:
[{'key': 'row1', 'column_families':
Row(cf1=
Row(cq1=[Row(value='value1', timestamp_micros=5000)],
cq2=[Row(value='value2', timestamp_micros=1000)]))}]
and what I want to assert it with is:
[{'key': 'row1', 'column_families': {'cf1':
{'cq2':
[BeamSchema_165279ce_43e8_4978_9b7b_3524cf48f6e7(value=b'value2', timestamp_micros=1000)],
'cq1':
[BeamSchema_165279ce_43e8_4978_9b7b_3524cf48f6e7(value=b'value1', timestamp_micros=5000)]}}}]
and the assert is incorrect even though the logic in terms of how its supposed to look is correct
Issue Priority
Priority: 2 (default / most bugs should be filed as P2)
Issue Components
What happened?
@derrickaw
There is a problem when trying to assert with beamSchema
config:
elements:
- {key: 'row1',
# Use explicit map syntax to match the actual output
column_families: {
cf1: {
cq1: [
{ value: "value1", timestamp_micros: 5000 }
],
cq2: [
{ value: "value2", timestamp_micros: 1000 }
]
}
}
}
in yaml this is converted to:
[{'key': 'row1', 'column_families':
Row(cf1=
Row(cq1=[Row(value='value1', timestamp_micros=5000)],
cq2=[Row(value='value2', timestamp_micros=1000)]))}]
and what I want to assert it with is:
[{'key': 'row1', 'column_families': {'cf1':
{'cq2':
[BeamSchema_165279ce_43e8_4978_9b7b_3524cf48f6e7(value=b'value2', timestamp_micros=1000)],
'cq1':
[BeamSchema_165279ce_43e8_4978_9b7b_3524cf48f6e7(value=b'value1', timestamp_micros=5000)]}}}]
and the assert is incorrect even though the logic in terms of how its supposed to look is correct
Issue Priority
Priority: 2 (default / most bugs should be filed as P2)
Issue Components