iframe-proxy | Sunbelt Computer Software

Repository navigation

# Init gevent

from gevent import monkey

monkey.patch_all()

import asyncio

import logging

from temporalio.client import Client

from temporalio.envconfig import ClientConfig

from gevent_async import workflow

from gevent_async.executor import GeventExecutor

def main():

logging.basicConfig(level=logging.INFO)

# Create single-worker gevent executor and run asyncio.run(async_main()) in

# it, waiting for result. This executor cannot be used for anything else in

# Temporal, it is just a single thread for running asyncio.

with GeventExecutor(max_workers=1) as executor:

executor.submit(asyncio.run, async_main()).result()

async def async_main():

# Connect client

config = ClientConfig.load_client_connect_config()

config.setdefault("target_host", "localhost:7233")

client = await Client.connect(**config)

# Run workflow

result = await client.execute_workflow(

workflow.GreetingWorkflow.run,

"Temporal",

id="gevent_async-workflow-id",

task_queue="gevent_async-task-queue",

)

logging.info(f"Workflow result: {result}")

if __name__ == "__main__":

main()