ayx_python_sdk.test_harness package¶
Submodules¶
ayx_python_sdk.test_harness.plugin_runner module¶
Class for running a plugin out of process.
- class ayx_python_sdk.test_harness.plugin_runner.PluginRunner(plugin_entrypoint: pathlib.Path, plugins_package: str, tool_name: str, input_metadata: List[Metadata], input_data: List[pd.DataFrame], config_xml: pathlib.Path, transport_type: str)[source]¶
Bases:
object
Class for running a plugin out of process with test data.
- async control_consumer(event_notify_complete: asyncio.locks.Event, event_plugin_ready: asyncio.locks.Event, resp_iterator: AsyncIterable[sdk_tool_service_v2_pb2.RecordTransferOut]) None [source]¶
Receives and handles Control msg responses from the server.
- async control_producer(event_notify_complete: asyncio.locks.Event, event_plugin_ready: asyncio.locks.Event) sdk_tool_service_v2_pb2.ControlIn [source]¶
Generate initial control messages, then wait for any new msgs to send from the queue.
- async record_transfer_producer(event_plugin_ready: asyncio.locks.Event) sdk_tool_service_v2_pb2.RecordTransferIn [source]¶
Send records to the plugin, notify client is done sending record data.
- async run_plugin_v2(mode: ayx_python_sdk.test_harness.plugin_runner.RunMode) None [source]¶
Run the plugin out of process.
ayx_python_sdk.test_harness.process_lifecycle_manager module¶
OS independent process management class.
ayx_python_sdk.test_harness.sdk_engine_service module¶
Test harness implementation of the SDK Engine service.
- class ayx_python_sdk.test_harness.sdk_engine_service.SdkEngineService[source]¶
-
Implementation of the SDK Engine service for the test harness.
- ConfirmSdkEngineServiceConnection(request, context)[source]¶
Confirm the connection with this server.
- PushOutgoingMetadata(request, context)[source]¶
Send any outgoing metadata from Sdk Plugin to SDK Engine Server.
Module contents¶
Python SDK gRPC Plugin Test harness.