import { getClient } from "@/api/AxiosClient"; import { WorkflowApiResponse, WorkflowRunApiResponse } from "@/api/types"; import { StatusBadge } from "@/components/StatusBadge"; import { Alert, AlertDescription, AlertTitle } from "@/components/ui/alert"; import { Button } from "@/components/ui/button"; import { Pagination, PaginationContent, PaginationItem, PaginationLink, PaginationNext, PaginationPrevious, } from "@/components/ui/pagination"; import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow, } from "@/components/ui/table"; import { Tooltip, TooltipContent, TooltipProvider, TooltipTrigger, } from "@/components/ui/tooltip"; import { useCredentialGetter } from "@/hooks/useCredentialGetter"; import { basicTimeFormat } from "@/util/timeFormat"; import { cn } from "@/util/utils"; import { ExclamationTriangleIcon, Pencil2Icon, PlayIcon, PlusIcon, ReloadIcon, } from "@radix-ui/react-icons"; import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query"; import { useNavigate, useSearchParams } from "react-router-dom"; import { stringify as convertToYAML } from "yaml"; import { ImportWorkflowButton } from "./ImportWorkflowButton"; import { WorkflowCreateYAMLRequest } from "./types/workflowYamlTypes"; import { WorkflowActions } from "./WorkflowActions"; import { WorkflowTitle } from "./WorkflowTitle"; const emptyWorkflowRequest: WorkflowCreateYAMLRequest = { title: "New Workflow", description: "", workflow_definition: { blocks: [], parameters: [], }, }; function Workflows() { const credentialGetter = useCredentialGetter(); const navigate = useNavigate(); const queryClient = useQueryClient(); const [searchParams, setSearchParams] = useSearchParams(); const workflowsPage = searchParams.get("workflowsPage") ? Number(searchParams.get("workflowsPage")) : 1; const workflowRunsPage = searchParams.get("workflowRunsPage") ? Number(searchParams.get("workflowRunsPage")) : 1; const { data: workflows, isLoading } = useQuery>({ queryKey: ["workflows", workflowsPage], queryFn: async () => { const client = await getClient(credentialGetter); const params = new URLSearchParams(); params.append("page", String(workflowsPage)); params.append("only_workflows", "true"); return client .get(`/workflows`, { params, }) .then((response) => response.data); }, }); const { data: workflowRuns, isLoading: workflowRunsIsLoading } = useQuery< Array >({ queryKey: ["workflowRuns", workflowRunsPage], queryFn: async () => { const client = await getClient(credentialGetter); const params = new URLSearchParams(); params.append("page", String(workflowRunsPage)); return client .get("/workflows/runs", { params, }) .then((response) => response.data); }, }); const createNewWorkflowMutation = useMutation({ mutationFn: async () => { const client = await getClient(credentialGetter); const yaml = convertToYAML(emptyWorkflowRequest); return client.post< typeof emptyWorkflowRequest, { data: WorkflowApiResponse } >("/workflows", yaml, { headers: { "Content-Type": "text/plain", }, }); }, onSuccess: (response) => { queryClient.invalidateQueries({ queryKey: ["workflows"], }); navigate(`/workflows/${response.data.workflow_permanent_id}/edit`); }, }); function handleRowClick( event: React.MouseEvent, workflowPermanentId: string, ) { if (event.ctrlKey || event.metaKey) { window.open( window.location.origin + `/workflows/${workflowPermanentId}/runs`, "_blank", "noopener,noreferrer", ); return; } navigate(`/workflows/${workflowPermanentId}/runs`); } function handleIconClick( event: React.MouseEvent, path: string, ) { if (event.ctrlKey || event.metaKey) { window.open( window.location.origin + path, "_blank", "noopener,noreferrer", ); return; } navigate(path); } const showExperimentalMessage = workflows?.length === 0 && workflowsPage === 1; return (
{showExperimentalMessage && (
Experimental Feature
Workflows are still in experimental mode. Please{" "} { book a demo }{" "} if you'd like to learn more. If you're feeling adventurous, create your first workflow!
)}

Workflows

ID Title Created At {isLoading ? ( Loading... ) : workflows?.length === 0 ? ( No workflows found ) : ( workflows?.map((workflow) => { return ( { handleRowClick(event, workflow.workflow_permanent_id); }} > {workflow.workflow_permanent_id} { handleRowClick(event, workflow.workflow_permanent_id); }} > {workflow.title} { handleRowClick(event, workflow.workflow_permanent_id); }} > {basicTimeFormat(workflow.created_at)}
Open in Editor Create New Run
); }) )}
{ if (workflowsPage === 1) { return; } const params = new URLSearchParams(); params.set( "workflowsPage", String(Math.max(1, workflowsPage - 1)), ); setSearchParams(params, { replace: true }); }} /> {workflowsPage} { const params = new URLSearchParams(); params.set("workflowsPage", String(workflowsPage + 1)); setSearchParams(params, { replace: true }); }} />

Workflow Runs

Workflow Run ID Workflow ID Workflow Title Status Created At {workflowRunsIsLoading ? ( Loading... ) : workflowRuns?.length === 0 ? ( No workflow runs found ) : ( workflowRuns?.map((workflowRun) => { return ( { if (event.ctrlKey || event.metaKey) { window.open( window.location.origin + `/workflows/${workflowRun.workflow_permanent_id}/${workflowRun.workflow_run_id}`, "_blank", "noopener,noreferrer", ); return; } navigate( `/workflows/${workflowRun.workflow_permanent_id}/${workflowRun.workflow_run_id}`, ); }} className="cursor-pointer" > {workflowRun.workflow_run_id} {workflowRun.workflow_permanent_id} {basicTimeFormat(workflowRun.created_at)} ); }) )}
{ if (workflowRunsPage === 1) { return; } const params = new URLSearchParams(); params.set( "workflowRunsPage", String(Math.max(1, workflowRunsPage - 1)), ); setSearchParams(params, { replace: true }); }} /> {workflowRunsPage} { const params = new URLSearchParams(); params.set("workflowRunsPage", String(workflowRunsPage + 1)); setSearchParams(params, { replace: true }); }} />
); } export { Workflows };