interoperability_production_queues
Monitor and manage message queues in InterSystems IRIS interoperability productions to track processing status and identify bottlenecks.
Instructions
Get Interoperability Production queues
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The handler function for the 'interoperability_production_queues' tool. It executes a SQL query to enumerate and list all Interoperability production queues from the IRIS database.@server.tool(description="Get Interoperability Production queues") async def interoperability_production_queues( ctx: Context, ) -> str: queues = [] db = ctx.db with db.cursor() as cur: sql = "select * from Ens.Queue_Enumerate()" cur.execute(sql) rows = cur.fetchall() queues = [", ".join([f"{cell}" for cell in row]) for row in rows] return "\n".join(queues)