Make run_worker_python.sh an executable

pull/21904/head
Lidi Zheng 5 years ago
parent 85eb4c17fb
commit 37bb427c03
  1. 0
      tools/run_tests/performance/run_worker_python_asyncio.sh
  2. 121
      tools/run_tests/performance/scenario_config.py

@ -828,72 +828,83 @@ class PythonAsyncIOLanguage:
return 1200
def scenarios(self):
yield _ping_pong_scenario(
'python_asyncio_generic_async_streaming_ping_pong',
rpc_type='STREAMING',
client_type='ASYNC_CLIENT',
server_type='ASYNC_GENERIC_SERVER',
use_generic_payload=True,
categories=[SMOKETEST, SCALABLE])
yield _ping_pong_scenario(
'python_asyncio_protobuf_async_streaming_ping_pong',
rpc_type='STREAMING',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER')
yield _ping_pong_scenario(
'python_asyncio_protobuf_async_unary_ping_pong',
rpc_type='UNARY',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER')
yield _ping_pong_scenario(
'python_asyncio_protobuf_async_unary_ping_pong',
rpc_type='UNARY',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER',
outstanding=64,
channels=1,
client_threads_per_cq=1,
server_threads_per_cq=1,
categories=[SMOKETEST, SCALABLE])
yield _ping_pong_scenario(
'python_asyncio_protobuf_async_unary_qps_unconstrained',
rpc_type='UNARY',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER',
unconstrained_client='async')
# yield _ping_pong_scenario(
# 'python_asyncio_generic_async_streaming_ping_pong',
# rpc_type='STREAMING',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_GENERIC_SERVER',
# use_generic_payload=True,
# categories=[SMOKETEST, SCALABLE])
yield _ping_pong_scenario(
'python_asyncio_protobuf_async_streaming_qps_unconstrained',
rpc_type='STREAMING',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER',
unconstrained_client='async')
# yield _ping_pong_scenario(
# 'python_asyncio_protobuf_async_streaming_ping_pong',
# rpc_type='STREAMING',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER')
yield _ping_pong_scenario(
'python_asyncio_to_cpp_protobuf_async_unary_ping_pong',
rpc_type='UNARY',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER',
server_language='python_asyncio',
async_server_threads=1,
categories=[SMOKETEST, SCALABLE])
# yield _ping_pong_scenario(
# 'python_asyncio_protobuf_async_unary_ping_pong',
# rpc_type='UNARY',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER')
yield _ping_pong_scenario(
'python_asyncio_to_cpp_protobuf_sync_streaming_ping_pong',
rpc_type='STREAMING',
client_type='SYNC_CLIENT',
server_type='ASYNC_SERVER',
server_language='python_asyncio',
async_server_threads=1)
# yield _ping_pong_scenario(
# 'python_asyncio_protobuf_async_unary_ping_pong',
# rpc_type='UNARY',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER',
# categories=[SMOKETEST, SCALABLE])
yield _ping_pong_scenario(
'python_asyncio_protobuf_async_unary_ping_pong_1MB',
rpc_type='UNARY',
client_type='ASYNC_CLIENT',
server_type='ASYNC_SERVER',
req_size=1024 * 1024,
resp_size=1024 * 1024,
categories=[SMOKETEST, SCALABLE])
# yield _ping_pong_scenario(
# 'python_asyncio_protobuf_async_unary_qps_unconstrained',
# rpc_type='UNARY',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER',
# unconstrained_client='async')
# yield _ping_pong_scenario(
# 'python_asyncio_protobuf_async_streaming_qps_unconstrained',
# rpc_type='STREAMING',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER',
# unconstrained_client='async')
# yield _ping_pong_scenario(
# 'python_asyncio_to_cpp_protobuf_async_unary_ping_pong',
# rpc_type='UNARY',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER',
# server_language='python_asyncio',
# async_server_threads=1,
# categories=[SMOKETEST, SCALABLE])
# yield _ping_pong_scenario(
# 'python_asyncio_to_cpp_protobuf_sync_streaming_ping_pong',
# rpc_type='STREAMING',
# client_type='SYNC_CLIENT',
# server_type='ASYNC_SERVER',
# server_language='python_asyncio',
# async_server_threads=1)
# yield _ping_pong_scenario(
# 'python_asyncio_protobuf_async_unary_ping_pong_1MB',
# rpc_type='UNARY',
# client_type='ASYNC_CLIENT',
# server_type='ASYNC_SERVER',
# req_size=1024 * 1024,
# resp_size=1024 * 1024,
# categories=[SMOKETEST, SCALABLE])
def __str__(self):
return 'python_asyncio'

Loading…
Cancel
Save