Function test_create_parquet_folder

test.py:122–150

()

async def test_create_parquet_folder():
    client = make_client()
    total_time = 0
    for _ in range(NUM_BENCHMARK_RUNS):
        start_time = time.time()

        await client.collect_parquet(
            "data",
            QUERY,
            hypersync.StreamConfig(
                hex_output=HexOutput.PREFIXED,
                column_mapping=hypersync.ColumnMapping(
                    trace={
                        TraceField.TRANSACTION_POSITION: DataType.INT32,
                    },
                    transaction={
                        TransactionField.BLOCK_NUMBER: DataType.INT64,
                        TransactionField.VALUE: DataType.FLOAT32,
                    },
                    decoded_log={
                        "value": DataType.FLOAT64,
                    },
                ),
                event_signature="Transfer(address indexed from, address indexed to, uint256 value)",
            ),
        )
        execution_time = (time.time() - start_time) * 1000
        total_time += execution_time
    print(f"create_parquet_folder time: {format(execution_time, '.9f')}ms")


async def test_send_req():