Unstructured API MCP Server

{ "cells": [ { "cell_type": "code", "execution_count": 4, "id": "dd74d3ac5677b80a", "metadata": { "ExecuteTime": { "end_time": "2025-03-21T14:16:46.432461Z", "start_time": "2025-03-21T14:16:46.429943Z" } }, "outputs": [], "source": [ "from pathlib import Path\n", "import os\n", "\n", "# Set working directory at top level or repository\n", "os.chdir(Path.cwd().parent)" ] }, { "cell_type": "code", "execution_count": 5, "id": "2bdb7a4f5bdef9c7", "metadata": { "ExecuteTime": { "end_time": "2025-03-21T14:16:46.703107Z", "start_time": "2025-03-21T14:16:46.434838Z" } }, "outputs": [], "source": [ "from minimal_client.client import MCPClient" ] }, { "cell_type": "code", "execution_count": 6, "id": "f01b8741d0649d3a", "metadata": { "ExecuteTime": { "end_time": "2025-03-21T14:16:46.757148Z", "start_time": "2025-03-21T14:16:46.755515Z" } }, "outputs": [], "source": [ "query = \"\"\"\n", "Hello, I would like you to create: a new S3 source connector and S3 destination connector. Call them 'MyExampleSourceS3-1' and 'MyExampleDestinationS3-1' respectively. S3 uri is 's3://crag-protected-but-non-sensitive/pluto/example_input/' and 's3://crag-protected-but-non-sensitive/pluto/example_output/'. Then I would like you to create and execute workflow with platinum strategy and previously created connectors MyExampleSourceS3-1 and MyExampleDestinationS3-1\n", "\"\"\"" ] }, { "cell_type": "code", "execution_count": 7, "id": "4c47528e3609376c", "metadata": { "ExecuteTime": { "end_time": "2025-03-21T14:17:52.128033Z", "start_time": "2025-03-21T14:16:46.764461Z" } }, "outputs": [ { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008000; text-decoration-color: #008000; font-weight: bold\">Query</span> (q/quit to end chat): </pre>\n" ], "text/plain": [ "\n", "\u001b[1;32mQuery\u001b[0m (q/quit to end chat): " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " Hello, I would like you to create: a new S3 source connector and S3 destination connector. Call them 'MyExampleSourceS3-1' and 'MyExampleDestinationS3-1' respectively. S3 uri is 's3://crag-protected-but-non-sensitive/pluto/example_input/' and 's3://crag-protected-but-non-sensitive/pluto/example_output/'. Then I would like you to create and execute workflow with platinum strategy and previously created connectors MyExampleSourceS3-1 and MyExampleDestinationS3-1\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "</pre>\n" ], "text/plain": [ "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "I'll help you create the S3 source and destination connectors, create a workflow using them, and execute it. I'll \n", "break this down into steps:\n", "\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span>. First, let's create the S3 source connector:\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "I'll help you create the S3 source and destination connectors, create a workflow using them, and execute it. I'll \n", "break this down into steps:\n", "\n", "\u001b[1;36m1\u001b[0m. First, let's create the S3 source connector:\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of create_source_connector with args {'name': 'MyExampleSourceS3-1', 'source_type': 's3', \n", "'type_specific_config': {'remote_url': 's3://crag-protected-but-non-sensitive/pluto/example_input/'}}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of create_source_connector with args {'name': 'MyExampleSourceS3-1', 'source_type': 's3', \n", "'type_specific_config': {'remote_url': 's3://crag-protected-but-non-sensitive/pluto/example_input/'}}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "S3 Source Connector Created:\n", "Name: MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span>\n", "ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">6abe10ae-cff3-49a8-b4a6-263d0b63e2cc</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "S3 Source Connector Created:\n", "Name: MyExampleSourceS3-\u001b[1;36m1\u001b[0m\n", "ID: \u001b[93m6abe10ae-cff3-49a8-b4a6-263d0b63e2cc\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span>. Now, let's create the S3 destination connector:\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "\u001b[1;36m2\u001b[0m. Now, let's create the S3 destination connector:\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of create_destination_connector with args {'name': 'MyExampleDestinationS3-1', 'destination_type':\n", "'s3', 'type_specific_config': {'remote_url': 's3://crag-protected-but-non-sensitive/pluto/example_output/'}}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of create_destination_connector with args {'name': 'MyExampleDestinationS3-1', 'destination_type':\n", "'s3', 'type_specific_config': {'remote_url': 's3://crag-protected-but-non-sensitive/pluto/example_output/'}}? \u001b[1;35m[y/n]\u001b[0m\n", "\u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "S3 Destination Connector Created:\n", "Name: MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span>\n", "ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">5732bc45-1d61-4ab8-96ce-9828f5b97ed3</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "S3 Destination Connector Created:\n", "Name: MyExampleDestinationS3-\u001b[1;36m1\u001b[0m\n", "ID: \u001b[93m5732bc45-1d61-4ab8-96ce-9828f5b97ed3\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">3</span>. Now, let's create a workflow with platinum strategy using these connectors:\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "\u001b[1;36m3\u001b[0m. Now, let's create a workflow with platinum strategy using these connectors:\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of create_workflow with args {'workflow_config': {'name': 'S3-to-S3-Platinum-Workflow', \n", "'workflow_type': 'platinum', 'source_id': '6abe10ae-cff3-49a8-b4a6-263d0b63e2cc', 'destination_id': \n", "'5732bc45-1d61-4ab8-96ce-9828f5b97ed3'}}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of create_workflow with args {'workflow_config': {'name': 'S3-to-S3-Platinum-Workflow', \n", "'workflow_type': 'platinum', 'source_id': '6abe10ae-cff3-49a8-b4a6-263d0b63e2cc', 'destination_id': \n", "'5732bc45-1d61-4ab8-96ce-9828f5b97ed3'}}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Workflow Information:\n", "Name: S3-to-S3-Platinum-Workflow\n", "ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">f6d6d203-7e5a-4d16-8561-6da7cbd2f33d</span>\n", "Status: WorkflowState.ACTIVE\n", "Type: WorkflowType.PLATINUM\n", "\n", "Sources:\n", " - <span style=\"color: #ffff00; text-decoration-color: #ffff00\">6abe10ae-cff3-49a8-b4a6-263d0b63e2cc</span>\n", "\n", "Destinations:\n", " - <span style=\"color: #ffff00; text-decoration-color: #ffff00\">5732bc45-1d61-4ab8-96ce-9828f5b97ed3</span>\n", "\n", "Schedule:\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Workflow Information:\n", "Name: S3-to-S3-Platinum-Workflow\n", "ID: \u001b[93mf6d6d203-7e5a-4d16-8561-6da7cbd2f33d\u001b[0m\n", "Status: WorkflowState.ACTIVE\n", "Type: WorkflowType.PLATINUM\n", "\n", "Sources:\n", " - \u001b[93m6abe10ae-cff3-49a8-b4a6-263d0b63e2cc\u001b[0m\n", "\n", "Destinations:\n", " - \u001b[93m5732bc45-1d61-4ab8-96ce-9828f5b97ed3\u001b[0m\n", "\n", "Schedule:\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">4</span>. Finally, let's execute the workflow:\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "\u001b[1;36m4\u001b[0m. Finally, let's execute the workflow:\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of run_workflow with args {'workflow_id': 'f6d6d203-7e5a-4d16-8561-6da7cbd2f33d'}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of run_workflow with args {'workflow_id': 'f6d6d203-7e5a-4d16-8561-6da7cbd2f33d'}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Workflow execution initiated: <span style=\"font-weight: bold\">&lt;</span><span style=\"color: #ff00ff; text-decoration-color: #ff00ff; font-weight: bold\">Response</span><span style=\"color: #000000; text-decoration-color: #000000\"> </span><span style=\"color: #000000; text-decoration-color: #000000; font-weight: bold\">[</span><span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">202</span><span style=\"color: #000000; text-decoration-color: #000000\"> Accepted</span><span style=\"color: #000000; text-decoration-color: #000000; font-weight: bold\">]</span><span style=\"font-weight: bold\">&gt;</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Workflow execution initiated: \u001b[1m<\u001b[0m\u001b[1;95mResponse\u001b[0m\u001b[39m \u001b[0m\u001b[1;39m[\u001b[0m\u001b[1;36m202\u001b[0m\u001b[39m Accepted\u001b[0m\u001b[1;39m]\u001b[0m\u001b[1m>\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "I've completed all the requested steps:\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span>. Created an S3 source connector named <span style=\"color: #008000; text-decoration-color: #008000\">\"MyExampleSourceS3-1\"</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span>. Created an S3 destination connector named <span style=\"color: #008000; text-decoration-color: #008000\">\"MyExampleDestinationS3-1\"</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">3</span>. Created a workflow using the platinum strategy and connected both connectors\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">4</span>. Executed the workflow\n", "\n", "The workflow has been initiated successfully. You can monitor its progress using the workflow ID: \n", "<span style=\"color: #ffff00; text-decoration-color: #ffff00\">f6d6d203-7e5a-4d16-8561-6da7cbd2f33d</span> or the various list and get info functions if needed. Would you like to check \n", "the status of the workflow or job?\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "I've completed all the requested steps:\n", "\u001b[1;36m1\u001b[0m. Created an S3 source connector named \u001b[32m\"MyExampleSourceS3-1\"\u001b[0m\n", "\u001b[1;36m2\u001b[0m. Created an S3 destination connector named \u001b[32m\"MyExampleDestinationS3-1\"\u001b[0m\n", "\u001b[1;36m3\u001b[0m. Created a workflow using the platinum strategy and connected both connectors\n", "\u001b[1;36m4\u001b[0m. Executed the workflow\n", "\n", "The workflow has been initiated successfully. You can monitor its progress using the workflow ID: \n", "\u001b[93mf6d6d203-7e5a-4d16-8561-6da7cbd2f33d\u001b[0m or the various list and get info functions if needed. Would you like to check \n", "the status of the workflow or job?\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008000; text-decoration-color: #008000; font-weight: bold\">Query</span> (q/quit to end chat): </pre>\n" ], "text/plain": [ "\n", "\u001b[1;32mQuery\u001b[0m (q/quit to end chat): " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " q\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "</pre>\n" ], "text/plain": [ "\n" ] }, "metadata": {}, "output_type": "display_data" } ], "source": [ "client = MCPClient()\n", "try:\n", " await client.connect_to_server(\"http://127.0.0.1:8080/sse\")\n", " await client.chat_loop()\n", "finally:\n", " await client.cleanup()" ] }, { "cell_type": "code", "execution_count": 8, "id": "184f86b3048f1060", "metadata": { "ExecuteTime": { "end_time": "2025-03-21T14:18:41.303666Z", "start_time": "2025-03-21T14:18:41.300758Z" } }, "outputs": [], "source": [ "query = \"\"\"\n", "I would like you to create and execute workflow with auto strategy and previously created connectors MyExampleSourceS3-1 and MyExampleDestinationS3-1. Call it S3toS3AutoWorkflow and run\n", "\"\"\"" ] }, { "cell_type": "code", "execution_count": 9, "id": "56cc846bff300daf", "metadata": { "ExecuteTime": { "end_time": "2025-03-21T14:19:33.371506Z", "start_time": "2025-03-21T14:18:43.108662Z" } }, "outputs": [ { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008000; text-decoration-color: #008000; font-weight: bold\">Query</span> (q/quit to end chat): </pre>\n" ], "text/plain": [ "\n", "\u001b[1;32mQuery\u001b[0m (q/quit to end chat): " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " I would like you to create and execute workflow with auto strategy and previously created connectors MyExampleSourceS3-1 and MyExampleDestinationS3-1. Call it S3toS3AutoWorkflow and run\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "</pre>\n" ], "text/plain": [ "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "I'll help you create and execute a workflow using the specified source and destination connectors. I'll break this \n", "down into a few steps:\n", "\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span>. First, I'll create a workflow with the given specifications. For a basic workflow with auto strategy, we can use\n", "the <span style=\"color: #008000; text-decoration-color: #008000\">\"basic\"</span> workflow type.\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "I'll help you create and execute a workflow using the specified source and destination connectors. I'll break this \n", "down into a few steps:\n", "\n", "\u001b[1;36m1\u001b[0m. First, I'll create a workflow with the given specifications. For a basic workflow with auto strategy, we can use\n", "the \u001b[32m\"basic\"\u001b[0m workflow type.\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of create_workflow with args {'workflow_config': {'name': 'S3toS3AutoWorkflow', 'workflow_type': \n", "'basic', 'source_id': 'MyExampleSourceS3-1', 'destination_id': 'MyExampleDestinationS3-1'}}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of create_workflow with args {'workflow_config': {'name': 'S3toS3AutoWorkflow', 'workflow_type': \n", "'basic', 'source_id': 'MyExampleSourceS3-1', 'destination_id': 'MyExampleDestinationS3-1'}}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Error creating workflow: <span style=\"font-weight: bold\">{</span><span style=\"color: #008000; text-decoration-color: #008000\">\"detail\"</span>:<span style=\"font-weight: bold\">[{</span><span style=\"color: #008000; text-decoration-color: #008000\">\"loc\"</span>:<span style=\"font-weight: bold\">[</span><span style=\"color: #008000; text-decoration-color: #008000\">\"body\"</span>,<span style=\"color: #008000; text-decoration-color: #008000\">\"source_id\"</span><span style=\"font-weight: bold\">]</span>,<span style=\"color: #008000; text-decoration-color: #008000\">\"msg\"</span>:<span style=\"color: #008000; text-decoration-color: #008000\">\"Input should be a valid UUID, invalid </span>\n", "<span style=\"color: #008000; text-decoration-color: #008000\">character: expected an optional prefix of `urn:uuid:` followed by [0-9a-fA-F-], found `M` at </span>\n", "<span style=\"color: #008000; text-decoration-color: #008000\">1\"</span>,<span style=\"color: #008000; text-decoration-color: #008000\">\"type\"</span>:<span style=\"color: #008000; text-decoration-color: #008000\">\"uuid_parsing\"</span><span style=\"font-weight: bold\">}</span>,<span style=\"font-weight: bold\">{</span><span style=\"color: #008000; text-decoration-color: #008000\">\"loc\"</span>:<span style=\"font-weight: bold\">[</span><span style=\"color: #008000; text-decoration-color: #008000\">\"body\"</span>,<span style=\"color: #008000; text-decoration-color: #008000\">\"destination_id\"</span><span style=\"font-weight: bold\">]</span>,<span style=\"color: #008000; text-decoration-color: #008000\">\"msg\"</span>:<span style=\"color: #008000; text-decoration-color: #008000\">\"Input should be a valid UUID, invalid character: </span>\n", "<span style=\"color: #008000; text-decoration-color: #008000\">expected an optional prefix of `urn:uuid:` followed by [0-9a-fA-F-], found `M` at 1\"</span>,<span style=\"color: #008000; text-decoration-color: #008000\">\"type\"</span>:<span style=\"color: #008000; text-decoration-color: #008000\">\"uuid_parsing\"</span><span style=\"font-weight: bold\">}]}</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Error creating workflow: \u001b[1m{\u001b[0m\u001b[32m\"detail\"\u001b[0m:\u001b[1m[\u001b[0m\u001b[1m{\u001b[0m\u001b[32m\"loc\"\u001b[0m:\u001b[1m[\u001b[0m\u001b[32m\"body\"\u001b[0m,\u001b[32m\"source_id\"\u001b[0m\u001b[1m]\u001b[0m,\u001b[32m\"msg\"\u001b[0m:\u001b[32m\"Input should be a valid UUID, invalid \u001b[0m\n", "\u001b[32mcharacter: expected an optional prefix of `urn:uuid:` followed by \u001b[0m\u001b[32m[\u001b[0m\u001b[32m0-9a-fA-F-\u001b[0m\u001b[32m]\u001b[0m\u001b[32m, found `M` at \u001b[0m\n", "\u001b[32m1\"\u001b[0m,\u001b[32m\"type\"\u001b[0m:\u001b[32m\"uuid_parsing\"\u001b[0m\u001b[1m}\u001b[0m,\u001b[1m{\u001b[0m\u001b[32m\"loc\"\u001b[0m:\u001b[1m[\u001b[0m\u001b[32m\"body\"\u001b[0m,\u001b[32m\"destination_id\"\u001b[0m\u001b[1m]\u001b[0m,\u001b[32m\"msg\"\u001b[0m:\u001b[32m\"Input should be a valid UUID, invalid character: \u001b[0m\n", "\u001b[32mexpected an optional prefix of `urn:uuid:` followed by \u001b[0m\u001b[32m[\u001b[0m\u001b[32m0-9a-fA-F-\u001b[0m\u001b[32m]\u001b[0m\u001b[32m, found `M` at 1\"\u001b[0m,\u001b[32m\"type\"\u001b[0m:\u001b[32m\"uuid_parsing\"\u001b[0m\u001b[1m}\u001b[0m\u001b[1m]\u001b[0m\u001b[1m}\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "I apologize for the error. It seems I need the actual UUID values for the source and destination connectors rather \n", "than just their names. Could you please provide the UUID values for:\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span>. The source connector <span style=\"color: #008000; text-decoration-color: #008000\">\"MyExampleSourceS3-1\"</span>\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span>. The destination connector <span style=\"color: #008000; text-decoration-color: #008000\">\"MyExampleDestinationS3-1\"</span>\n", "\n", "These would be long strings of characters in the format like <span style=\"color: #008000; text-decoration-color: #008000\">\"12345678-1234-5678-1234-567812345678\"</span>. Once you \n", "provide these UUIDs, I can create and run the workflow for you.\n", "\n", "To help find these IDs, you can use the list_sources and list_destinations commands if needed. Would you like me to\n", "help you find these IDs?\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "I apologize for the error. It seems I need the actual UUID values for the source and destination connectors rather \n", "than just their names. Could you please provide the UUID values for:\n", "\u001b[1;36m1\u001b[0m. The source connector \u001b[32m\"MyExampleSourceS3-1\"\u001b[0m\n", "\u001b[1;36m2\u001b[0m. The destination connector \u001b[32m\"MyExampleDestinationS3-1\"\u001b[0m\n", "\n", "These would be long strings of characters in the format like \u001b[32m\"12345678-1234-5678-1234-567812345678\"\u001b[0m. Once you \n", "provide these UUIDs, I can create and run the workflow for you.\n", "\n", "To help find these IDs, you can use the list_sources and list_destinations commands if needed. Would you like me to\n", "help you find these IDs?\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008000; text-decoration-color: #008000; font-weight: bold\">Query</span> (q/quit to end chat): </pre>\n" ], "text/plain": [ "\n", "\u001b[1;32mQuery\u001b[0m (q/quit to end chat): " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "</pre>\n" ], "text/plain": [ "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "I'll help you find the UUIDs by listing both the sources and destinations.\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "I'll help you find the UUIDs by listing both the sources and destinations.\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of list_sources with args {'source_type': 's3'}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of list_sources with args {'source_type': 's3'}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Available sources:\n", "- cool conector <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">207ac389-d571-42c1-ba59-606121ff77e9</span><span style=\"font-weight: bold\">)</span>\n", "- MCPS3MegaSource <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">e852aaa4-10aa-43e6-afe3-33aafa147d9f</span><span style=\"font-weight: bold\">)</span>\n", "- MCPS3MegaSource <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">edca8aae-b6b3-449e-b5b0-e95db40f23f5</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">2568dccd-44ab-42b9-b636-8fd3293c94f3</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">6abe10ae-cff3-49a8-b4a6-263d0b63e2cc</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">cf16e8c7-6994-41d3-84f9-865c55a34bad</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">8db9508a-23a4-4bd0-8ea0-bef89c4326e1</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">c0aa92e2-84aa-459f-b455-8111817946c7</span><span style=\"font-weight: bold\">)</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Available sources:\n", "- cool conector \u001b[1m(\u001b[0mID: \u001b[93m207ac389-d571-42c1-ba59-606121ff77e9\u001b[0m\u001b[1m)\u001b[0m\n", "- MCPS3MegaSource \u001b[1m(\u001b[0mID: \u001b[93me852aaa4-10aa-43e6-afe3-33aafa147d9f\u001b[0m\u001b[1m)\u001b[0m\n", "- MCPS3MegaSource \u001b[1m(\u001b[0mID: \u001b[93medca8aae-b6b3-449e-b5b0-e95db40f23f5\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleSourceS3-\u001b[1;36m1\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m2568dccd-44ab-42b9-b636-8fd3293c94f3\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleSourceS3-\u001b[1;36m1\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m6abe10ae-cff3-49a8-b4a6-263d0b63e2cc\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleSourceS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93mcf16e8c7-6994-41d3-84f9-865c55a34bad\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleSourceS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m8db9508a-23a4-4bd0-8ea0-bef89c4326e1\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleSourceS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93mc0aa92e2-84aa-459f-b455-8111817946c7\u001b[0m\u001b[1m)\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of list_destinations with args {'destination_type': 's3'}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of list_destinations with args {'destination_type': 's3'}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Available destinations:\n", "- MCPS3Dest <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">429be83b-cfc4-43e9-afac-adb1b179b115</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">5732bc45-1d61-4ab8-96ce-9828f5b97ed3</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">02edcd8f-ff01-44b4-943b-38751f8906ee</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">692cce21-4139-4e78-b8f6-cf5bfab98b7a</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">d31b6e92-531b-480c-b971-a20b09c23d92</span><span style=\"font-weight: bold\">)</span>\n", "- MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">2</span> <span style=\"font-weight: bold\">(</span>ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">835bb5ac-4ad0-40a7-86c6-cf56aaf862a8</span><span style=\"font-weight: bold\">)</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Available destinations:\n", "- MCPS3Dest \u001b[1m(\u001b[0mID: \u001b[93m429be83b-cfc4-43e9-afac-adb1b179b115\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleDestinationS3-\u001b[1;36m1\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m5732bc45-1d61-4ab8-96ce-9828f5b97ed3\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleDestinationS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m02edcd8f-ff01-44b4-943b-38751f8906ee\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleDestinationS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m692cce21-4139-4e78-b8f6-cf5bfab98b7a\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleDestinationS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93md31b6e92-531b-480c-b971-a20b09c23d92\u001b[0m\u001b[1m)\u001b[0m\n", "- MyExampleDestinationS3-\u001b[1;36m2\u001b[0m \u001b[1m(\u001b[0mID: \u001b[93m835bb5ac-4ad0-40a7-86c6-cf56aaf862a8\u001b[0m\u001b[1m)\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "I found the IDs for both connectors. Now I'll create the workflow using these UUIDs:\n", "\n", "Source ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">2568dccd-44ab-42b9-b636-8fd3293c94f3</span> <span style=\"font-weight: bold\">(</span>for MyExampleSourceS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span><span style=\"font-weight: bold\">)</span>\n", "Destination ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">5732bc45-1d61-4ab8-96ce-9828f5b97ed3</span> <span style=\"font-weight: bold\">(</span>for MyExampleDestinationS3-<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">1</span><span style=\"font-weight: bold\">)</span>\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "I found the IDs for both connectors. Now I'll create the workflow using these UUIDs:\n", "\n", "Source ID: \u001b[93m2568dccd-44ab-42b9-b636-8fd3293c94f3\u001b[0m \u001b[1m(\u001b[0mfor MyExampleSourceS3-\u001b[1;36m1\u001b[0m\u001b[1m)\u001b[0m\n", "Destination ID: \u001b[93m5732bc45-1d61-4ab8-96ce-9828f5b97ed3\u001b[0m \u001b[1m(\u001b[0mfor MyExampleDestinationS3-\u001b[1;36m1\u001b[0m\u001b[1m)\u001b[0m\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of create_workflow with args {'workflow_config': {'name': 'S3toS3AutoWorkflow', 'workflow_type': \n", "'basic', 'source_id': '2568dccd-44ab-42b9-b636-8fd3293c94f3', 'destination_id': \n", "'5732bc45-1d61-4ab8-96ce-9828f5b97ed3'}}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of create_workflow with args {'workflow_config': {'name': 'S3toS3AutoWorkflow', 'workflow_type': \n", "'basic', 'source_id': '2568dccd-44ab-42b9-b636-8fd3293c94f3', 'destination_id': \n", "'5732bc45-1d61-4ab8-96ce-9828f5b97ed3'}}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Workflow Information:\n", "Name: S3toS3AutoWorkflow\n", "ID: <span style=\"color: #ffff00; text-decoration-color: #ffff00\">0ac72f8a-26cd-4bc4-8450-760d4c9156ad</span>\n", "Status: WorkflowState.ACTIVE\n", "Type: WorkflowType.BASIC\n", "\n", "Sources:\n", " - <span style=\"color: #ffff00; text-decoration-color: #ffff00\">2568dccd-44ab-42b9-b636-8fd3293c94f3</span>\n", "\n", "Destinations:\n", " - <span style=\"color: #ffff00; text-decoration-color: #ffff00\">5732bc45-1d61-4ab8-96ce-9828f5b97ed3</span>\n", "\n", "Schedule:\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Workflow Information:\n", "Name: S3toS3AutoWorkflow\n", "ID: \u001b[93m0ac72f8a-26cd-4bc4-8450-760d4c9156ad\u001b[0m\n", "Status: WorkflowState.ACTIVE\n", "Type: WorkflowType.BASIC\n", "\n", "Sources:\n", " - \u001b[93m2568dccd-44ab-42b9-b636-8fd3293c94f3\u001b[0m\n", "\n", "Destinations:\n", " - \u001b[93m5732bc45-1d61-4ab8-96ce-9828f5b97ed3\u001b[0m\n", "\n", "Schedule:\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "Great! The workflow has been created successfully. Now, let's run it:\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "Great! The workflow has been created successfully. Now, let's run it:\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL CALL</span>\n", "Accept execution of run_workflow with args {'workflow_id': '0ac72f8a-26cd-4bc4-8450-760d4c9156ad'}? <span style=\"color: #800080; text-decoration-color: #800080; font-weight: bold\">[y/n]</span> <span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">(y)</span>: </pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL CALL\u001b[0m\n", "Accept execution of run_workflow with args {'workflow_id': '0ac72f8a-26cd-4bc4-8450-760d4c9156ad'}? \u001b[1;35m[y/n]\u001b[0m \u001b[1;36m(y)\u001b[0m: " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " y\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">TOOL OUTPUT</span>:\n", "Workflow execution initiated: <span style=\"font-weight: bold\">&lt;</span><span style=\"color: #ff00ff; text-decoration-color: #ff00ff; font-weight: bold\">Response</span><span style=\"color: #000000; text-decoration-color: #000000\"> </span><span style=\"color: #000000; text-decoration-color: #000000; font-weight: bold\">[</span><span style=\"color: #008080; text-decoration-color: #008080; font-weight: bold\">202</span><span style=\"color: #000000; text-decoration-color: #000000\"> Accepted</span><span style=\"color: #000000; text-decoration-color: #000000; font-weight: bold\">]</span><span style=\"font-weight: bold\">&gt;</span>\n", "\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;36mTOOL OUTPUT\u001b[0m:\n", "Workflow execution initiated: \u001b[1m<\u001b[0m\u001b[1;95mResponse\u001b[0m\u001b[39m \u001b[0m\u001b[1;39m[\u001b[0m\u001b[1;36m202\u001b[0m\u001b[39m Accepted\u001b[0m\u001b[1;39m]\u001b[0m\u001b[1m>\u001b[0m\n", "\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #800000; text-decoration-color: #800000; font-weight: bold\">ASSISTANT</span>\n", "The workflow has been successfully created and started! The workflow will process your documents using the auto \n", "strategy, taking them from your S3 source and storing the results in your S3 destination.\n", "\n", "You can check the status of this job using the list_jobs or get_job_info commands if you'd like. Would you like me \n", "to check the status of the job for you?\n", "</pre>\n" ], "text/plain": [ "\n", "\u001b[1;31mASSISTANT\u001b[0m\n", "The workflow has been successfully created and started! The workflow will process your documents using the auto \n", "strategy, taking them from your S3 source and storing the results in your S3 destination.\n", "\n", "You can check the status of this job using the list_jobs or get_job_info commands if you'd like. Would you like me \n", "to check the status of the job for you?\n" ] }, "metadata": {}, "output_type": "display_data" }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "<span style=\"color: #008000; text-decoration-color: #008000; font-weight: bold\">Query</span> (q/quit to end chat): </pre>\n" ], "text/plain": [ "\n", "\u001b[1;32mQuery\u001b[0m (q/quit to end chat): " ] }, "metadata": {}, "output_type": "display_data" }, { "name": "stdin", "output_type": "stream", "text": [ " q\n" ] }, { "data": { "text/html": [ "<pre style=\"white-space:pre;overflow-x:auto;line-height:normal;font-family:Menlo,'DejaVu Sans Mono',consolas,'Courier New',monospace\">\n", "</pre>\n" ], "text/plain": [ "\n" ] }, "metadata": {}, "output_type": "display_data" } ], "source": [ "client = MCPClient()\n", "try:\n", " await client.connect_to_server(\"http://127.0.0.1:8080/sse\")\n", " await client.chat_loop()\n", "finally:\n", " await client.cleanup()" ] }, { "cell_type": "code", "execution_count": null, "id": "577992412b485848", "metadata": {}, "outputs": [], "source": [] } ], "metadata": { "kernelspec": { "display_name": "Python 3 (ipykernel)", "language": "python", "name": "python3" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.12.3" } }, "nbformat": 4, "nbformat_minor": 5 }