o tBh @sdddlZddlmZddlmZmZmZddlmZm Z m Z m Z m Z ddl mZGdddeZdS)N) isawaitable)AsyncGenerator Awaitablecast) DocumentNodeExecutionResult GraphQLSchemaexecute subscribe)AsyncTransportc@sfeZdZdZdefddZddZddZd ed e fd d Z e d dZ d ed e e dffddZdS)LocalSchemaTransportzAA transport for executing GraphQL queries against a local schema.schemacCs ||_dS)z{Initialize the transport with the given local schema. :param schema: Local schema as GraphQLSchema object N)r )selfr rq/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/gql/transport/local_schema.py__init__ s zLocalSchemaTransport.__init__cdS)z'No connection needed on local transportNrrrrrconnectzLocalSchemaTransport.connectcr)z"No close needed on local transportNrrrrrcloserzLocalSchemaTransport.closedocumentreturncsRt|j|g|Ri|}t|r ttt|}|IdH}|Stt|}|}|S)z@Execute the provided document AST for on a local GraphQL Schema.N)r r rrrr)rrargskwargsresult_or_awaitableexecution_resultrrrr s  zLocalSchemaTransport.executecst|r |IdHS|S)zTThis method is necessary to work with graphql-core versions < and >= 3.3.0a3N)asyncio iscoroutine)objrrr_await_if_necessary4sz(LocalSchemaTransport._await_if_necessaryNcOsZ|t|j|g|Ri|IdH}t|tr|VdS|2z 3dHW}|Vq 6dS)zSend a subscription and receive the results using an async generator The results are sent as an ExecutionResult object N)r r r isinstancer)rrrrsubscribe_resultresultrrrr :s   zLocalSchemaTransport.subscribe)__name__ __module__ __qualname____doc__rrrrrrr staticmethodr rr rrrrr s&     r )rinspectrtypingrrrgraphqlrrrr r gql.transportr r rrrrs