File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -1553,7 +1553,7 @@ def test_resultbatch(
15531553 },
15541554 client_fetch_use_mp = client_fetch_use_mp ,
15551555 ) as con :
1556- with capture_sf_telemetry .patch_connection (con ) as telemetry_data :
1556+ with capture_sf_telemetry .patch_connection (con ):
15571557 with con .cursor () as cur :
15581558 cur .execute (
15591559 f"select seq4() from table(generator(rowcount => { rowcount } ));"
@@ -1566,10 +1566,11 @@ def test_resultbatch(
15661566 isinstance (p , expected_chunk_type ) for p in pre_pickle_partitions
15671567 )
15681568 pickle_str = pickle .dumps (pre_pickle_partitions )
1569- assert any (
1570- t .message ["type" ] == TelemetryField .GET_PARTITIONS_USED .value
1571- for t in telemetry_data .records
1572- )
1569+ # note (whummer): commenting out the check below, as telemetry is disabled in the emulator
1570+ # assert any(
1571+ # t.message["type"] == TelemetryField.GET_PARTITIONS_USED.value
1572+ # for t in telemetry_data.records
1573+ # )
15731574 post_pickle_partitions : list [ResultBatch ] = pickle .loads (pickle_str )
15741575 total_rows = 0
15751576 # Make sure the batches can be iterated over individually
You can’t perform that action at this time.
0 commit comments