[DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch #30104
6 fail, 17 skipped in 7m 45s
23 tests 0 ✅ 7m 45s ⏱️
1 suites 17 💤
1 files 6 ❌
Results for commit b72bb15.
Annotations
Check warning on line 0 in apache_beam.io.gcp.bigtableio_it_test.TestReadFromBigTableIT
github-actions / Test Results
test_read_xlang (apache_beam.io.gcp.bigtableio_it_test.TestReadFromBigTableIT) failed
sdks/python/pytest_transformService.xml [took 1m 18s]
Raw output
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Application error processing RPC"
debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:13:38.489682243+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
>
self = <apache_beam.io.gcp.bigtableio_it_test.TestReadFromBigTableIT testMethod=test_read_xlang>
def test_read_xlang(self):
# create rows and retrieve expected cells
expected_cells = self.add_rows(
num_rows=5, num_families=3, num_columns_per_family=4)
with beam.Pipeline(argv=self.args) as p:
cells = (
p
> | bigtableio.ReadFromBigtable(
project_id=self.project,
instance_id=self.instance.instance_id,
table_id=self.table.table_id,
expansion_service=self.expansion_service)
| "Extract cells" >> beam.Map(lambda row: row._cells))
apache_beam/io/gcp/bigtableio_it_test.py:141:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/io/gcp/bigtableio.py:318: in __init__
self.schematransform_config = SchemaAwareExternalTransform.discover_config(
apache_beam/transforms/external.py:495: in discover_config
schematransforms = SchemaAwareExternalTransform.discover(
apache_beam/transforms/external.py:441: in discover
return list(cls.discover_iter(expansion_service, ignore_errors))
apache_beam/transforms/external.py:446: in discover_iter
discover_response = service.DiscoverSchemaTransform(
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1160: in __call__
return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
state = <grpc._channel._RPCState object at 0x78bf0b5a1150>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x78bf0b5a1000>
with_call = False, deadline = None
def _end_unary_response_blocking(
state: _RPCState,
call: cygrpc.SegregatedCall,
with_call: bool,
deadline: Optional[float],
) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
if state.code is grpc.StatusCode.OK:
if with_call:
rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
return state.response, rendezvous
else:
return state.response
else:
> raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNKNOWN
E details = "Application error processing RPC"
E debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:13:38.489682243+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
E >
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1003: _InactiveRpcError
Check warning on line 0 in apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT
github-actions / Test Results
test_delete_cells_mutation (apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT) failed
sdks/python/pytest_transformService.xml [took 1m 18s]
Raw output
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Application error processing RPC"
debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:14:58.18158051+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
>
self = <apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT testMethod=test_delete_cells_mutation>
def test_delete_cells_mutation(self):
col_fam = self.table.column_family('col_fam')
col_fam.create()
# write a row with two columns to the table beforehand.
write_row: DirectRow = DirectRow('key-1', self.table)
write_row.set_cell('col_fam', b'col-1', b'val-1')
write_row.set_cell('col_fam', b'col-2', b'val-2')
write_row.commit()
# prepare a row that will delete cells in one of the columns.
delete_row: DirectRow = DirectRow('key-1')
delete_row.delete_cell('col_fam', b'col-1')
> self.run_pipeline([delete_row])
apache_beam/io/gcp/bigtableio_it_test.py:288:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/io/gcp/bigtableio_it_test.py:214: in run_pipeline
| bigtableio.WriteToBigTable(
apache_beam/io/gcp/bigtableio.py:219: in __init__
SchemaAwareExternalTransform.discover_config(
apache_beam/transforms/external.py:495: in discover_config
schematransforms = SchemaAwareExternalTransform.discover(
apache_beam/transforms/external.py:441: in discover
return list(cls.discover_iter(expansion_service, ignore_errors))
apache_beam/transforms/external.py:446: in discover_iter
discover_response = service.DiscoverSchemaTransform(
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1160: in __call__
return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
state = <grpc._channel._RPCState object at 0x78bf0b5ad7d0>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x78bf0b5ad8c0>
with_call = False, deadline = None
def _end_unary_response_blocking(
state: _RPCState,
call: cygrpc.SegregatedCall,
with_call: bool,
deadline: Optional[float],
) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
if state.code is grpc.StatusCode.OK:
if with_call:
rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
return state.response, rendezvous
else:
return state.response
else:
> raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNKNOWN
E details = "Application error processing RPC"
E debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:14:58.18158051+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
E >
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1003: _InactiveRpcError
Check warning on line 0 in apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT
github-actions / Test Results
test_delete_cells_with_timerange_mutation (apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT) failed
sdks/python/pytest_transformService.xml [took 1m 13s]
Raw output
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Application error processing RPC"
debug_error_string = "UNKNOWN:Error received from peer {grpc_message:"Application error processing RPC", grpc_status:2, created_time:"2024-02-06T00:16:11.614814078+00:00"}"
>
self = <apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT testMethod=test_delete_cells_with_timerange_mutation>
def test_delete_cells_with_timerange_mutation(self):
col_fam = self.table.column_family('col_fam')
col_fam.create()
# write two cells in a column to the table beforehand.
write_row: DirectRow = DirectRow('key-1', self.table)
write_row.set_cell(
'col_fam',
b'col',
b'val',
datetime.fromtimestamp(100_000_000, tz=timezone.utc))
write_row.commit()
write_row.set_cell(
'col_fam',
b'col',
b'new-val',
datetime.fromtimestamp(200_000_000, tz=timezone.utc))
write_row.commit()
# prepare a row that will delete cells within a timestamp range.
delete_row: DirectRow = DirectRow('key-1')
delete_row.delete_cell(
'col_fam',
b'col',
time_range=TimestampRange(
start=datetime.fromtimestamp(99_999_999, tz=timezone.utc),
end=datetime.fromtimestamp(100_000_001, tz=timezone.utc)))
> self.run_pipeline([delete_row])
apache_beam/io/gcp/bigtableio_it_test.py:329:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/io/gcp/bigtableio_it_test.py:214: in run_pipeline
| bigtableio.WriteToBigTable(
apache_beam/io/gcp/bigtableio.py:219: in __init__
SchemaAwareExternalTransform.discover_config(
apache_beam/transforms/external.py:495: in discover_config
schematransforms = SchemaAwareExternalTransform.discover(
apache_beam/transforms/external.py:441: in discover
return list(cls.discover_iter(expansion_service, ignore_errors))
apache_beam/transforms/external.py:446: in discover_iter
discover_response = service.DiscoverSchemaTransform(
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1160: in __call__
return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
state = <grpc._channel._RPCState object at 0x78bf082dc210>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x78bf082dd500>
with_call = False, deadline = None
def _end_unary_response_blocking(
state: _RPCState,
call: cygrpc.SegregatedCall,
with_call: bool,
deadline: Optional[float],
) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
if state.code is grpc.StatusCode.OK:
if with_call:
rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
return state.response, rendezvous
else:
return state.response
else:
> raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNKNOWN
E details = "Application error processing RPC"
E debug_error_string = "UNKNOWN:Error received from peer {grpc_message:"Application error processing RPC", grpc_status:2, created_time:"2024-02-06T00:16:11.614814078+00:00"}"
E >
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1003: _InactiveRpcError
Check warning on line 0 in apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT
github-actions / Test Results
test_delete_column_family_mutation (apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT) failed
sdks/python/pytest_transformService.xml [took 1m 15s]
Raw output
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Application error processing RPC"
debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:17:26.997183842+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
>
self = <apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT testMethod=test_delete_column_family_mutation>
def test_delete_column_family_mutation(self):
# create two column families
col_fam = self.table.column_family('col_fam-1')
col_fam.create()
col_fam = self.table.column_family('col_fam-2')
col_fam.create()
# write a row with values in both column families to the table beforehand.
write_row: DirectRow = DirectRow('key-1', self.table)
write_row.set_cell('col_fam-1', b'col', b'val')
write_row.set_cell('col_fam-2', b'col', b'val')
write_row.commit()
# prepare a row that will delete a column family from the row
delete_row: DirectRow = DirectRow('key-1')
delete_row.delete_cells('col_fam-1', delete_row.ALL_COLUMNS)
> self.run_pipeline([delete_row])
apache_beam/io/gcp/bigtableio_it_test.py:359:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/io/gcp/bigtableio_it_test.py:214: in run_pipeline
| bigtableio.WriteToBigTable(
apache_beam/io/gcp/bigtableio.py:219: in __init__
SchemaAwareExternalTransform.discover_config(
apache_beam/transforms/external.py:495: in discover_config
schematransforms = SchemaAwareExternalTransform.discover(
apache_beam/transforms/external.py:441: in discover
return list(cls.discover_iter(expansion_service, ignore_errors))
apache_beam/transforms/external.py:446: in discover_iter
discover_response = service.DiscoverSchemaTransform(
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1160: in __call__
return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
state = <grpc._channel._RPCState object at 0x78bf082c9d90>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x78bf082ca8c0>
with_call = False, deadline = None
def _end_unary_response_blocking(
state: _RPCState,
call: cygrpc.SegregatedCall,
with_call: bool,
deadline: Optional[float],
) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
if state.code is grpc.StatusCode.OK:
if with_call:
rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
return state.response, rendezvous
else:
return state.response
else:
> raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNKNOWN
E details = "Application error processing RPC"
E debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:17:26.997183842+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
E >
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1003: _InactiveRpcError
Check warning on line 0 in apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT
github-actions / Test Results
test_delete_row_mutation (apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT) failed
sdks/python/pytest_transformService.xml [took 1m 13s]
Raw output
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Application error processing RPC"
debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:18:40.773558084+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
>
self = <apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT testMethod=test_delete_row_mutation>
def test_delete_row_mutation(self):
write_row1: DirectRow = DirectRow('key-1', self.table)
write_row2: DirectRow = DirectRow('key-2', self.table)
col_fam = self.table.column_family('col_fam')
col_fam.create()
# write a couple of rows to the table beforehand
write_row1.set_cell('col_fam', b'col', b'val-1')
write_row1.commit()
write_row2.set_cell('col_fam', b'col', b'val-2')
write_row2.commit()
# prepare a row that will delete itself
delete_row: DirectRow = DirectRow('key-1')
delete_row.delete()
> self.run_pipeline([delete_row])
apache_beam/io/gcp/bigtableio_it_test.py:387:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/io/gcp/bigtableio_it_test.py:214: in run_pipeline
| bigtableio.WriteToBigTable(
apache_beam/io/gcp/bigtableio.py:219: in __init__
SchemaAwareExternalTransform.discover_config(
apache_beam/transforms/external.py:495: in discover_config
schematransforms = SchemaAwareExternalTransform.discover(
apache_beam/transforms/external.py:441: in discover
return list(cls.discover_iter(expansion_service, ignore_errors))
apache_beam/transforms/external.py:446: in discover_iter
discover_response = service.DiscoverSchemaTransform(
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1160: in __call__
return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
state = <grpc._channel._RPCState object at 0x78bf08319510>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x78bf0834f540>
with_call = False, deadline = None
def _end_unary_response_blocking(
state: _RPCState,
call: cygrpc.SegregatedCall,
with_call: bool,
deadline: Optional[float],
) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
if state.code is grpc.StatusCode.OK:
if with_call:
rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
return state.response, rendezvous
else:
return state.response
else:
> raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNKNOWN
E details = "Application error processing RPC"
E debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:18:40.773558084+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
E >
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1003: _InactiveRpcError
Check warning on line 0 in apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT
github-actions / Test Results
test_set_mutation (apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT) failed
sdks/python/pytest_transformService.xml [took 1m 13s]
Raw output
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Application error processing RPC"
debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:19:54.548442166+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
>
self = <apache_beam.io.gcp.bigtableio_it_test.TestWriteToBigtableXlangIT testMethod=test_set_mutation>
def test_set_mutation(self):
row1: DirectRow = DirectRow('key-1')
row2: DirectRow = DirectRow('key-2')
col_fam = self.table.column_family('col_fam')
col_fam.create()
# expected cells
row1_col1_cell = Cell(b'val1-1', 100_000_000)
row1_col2_cell = Cell(b'val1-2', 200_000_000)
row2_col1_cell = Cell(b'val2-1', 100_000_000)
row2_col2_cell = Cell(b'val2-2', 200_000_000)
# When setting this cell, we won't set a timestamp. We expect the timestamp
# to default to -1, and Bigtable will set it to system time at insertion.
row2_col1_no_timestamp = Cell(b'val2-2-notimestamp', time.time())
# rows sent to write transform
row1.set_cell(
'col_fam', b'col-1', row1_col1_cell.value, row1_col1_cell.timestamp)
row1.set_cell(
'col_fam', b'col-2', row1_col2_cell.value, row1_col2_cell.timestamp)
row2.set_cell(
'col_fam', b'col-1', row2_col1_cell.value, row2_col1_cell.timestamp)
row2.set_cell(
'col_fam', b'col-2', row2_col2_cell.value, row2_col2_cell.timestamp)
# don't set a timestamp here. it should default to -1
row2.set_cell('col_fam', b'col-no-timestamp', row2_col1_no_timestamp.value)
> self.run_pipeline([row1, row2])
apache_beam/io/gcp/bigtableio_it_test.py:246:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/io/gcp/bigtableio_it_test.py:214: in run_pipeline
| bigtableio.WriteToBigTable(
apache_beam/io/gcp/bigtableio.py:219: in __init__
SchemaAwareExternalTransform.discover_config(
apache_beam/transforms/external.py:495: in discover_config
schematransforms = SchemaAwareExternalTransform.discover(
apache_beam/transforms/external.py:441: in discover
return list(cls.discover_iter(expansion_service, ignore_errors))
apache_beam/transforms/external.py:446: in discover_iter
discover_response = service.DiscoverSchemaTransform(
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1160: in __call__
return _end_unary_response_blocking(state, call, False, None)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
state = <grpc._channel._RPCState object at 0x78bf0835e990>
call = <grpc._cython.cygrpc.SegregatedCall object at 0x78bf0835de80>
with_call = False, deadline = None
def _end_unary_response_blocking(
state: _RPCState,
call: cygrpc.SegregatedCall,
with_call: bool,
deadline: Optional[float],
) -> Union[ResponseType, Tuple[ResponseType, grpc.Call]]:
if state.code is grpc.StatusCode.OK:
if with_call:
rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
return state.response, rendezvous
else:
return state.response
else:
> raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNKNOWN
E details = "Application error processing RPC"
E debug_error_string = "UNKNOWN:Error received from peer {created_time:"2024-02-06T00:19:54.548442166+00:00", grpc_status:2, grpc_message:"Application error processing RPC"}"
E >
../../build/gradleenv/1922375555/lib/python3.11/site-packages/grpc/_channel.py:1003: _InactiveRpcError