iframe-proxy | Sunbelt Computer Software

Repository navigation

import asyncio

from uuid import uuid4

from temporalio.client import Client

from temporalio.envconfig import ClientConfig

from worker_specific_task_queues.tasks import FileProcessing

async def main():

# Connect client

config = ClientConfig.load_client_connect_config()

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

client = await Client.connect(**config)

# Start 10 concurrent workflows

futures = []

for idx in range(10):

result = client.execute_workflow(

FileProcessing.run,

id=f"worker_specific_task_queue-workflow-id-{idx}",

task_queue="worker_specific_task_queue-distribution-queue",

)

await asyncio.sleep(0.1)

futures.append(result)

checksums = await asyncio.gather(*futures)

print("\n".join([f"Output checksums:"] + checksums))

if __name__ == "__main__":

asyncio.run(main())