MCPcopy Index your code
hub / github.com/OpenPipe/OpenPipe / processNode.task.ts

File processNode.task.ts

app/src/server/tasks/nodes/processNodes/processNode.task.ts:None–None  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1import type { NodeType } from "@prisma/client";
2import type { TaskSpec } from "graphile-worker";
3import type { ChatCompletionMessage } from "openai/resources";
4import { from, lastValueFrom } from "rxjs";

Callers

nothing calls this directly

Calls 7

invalidateNodeEntriesFunction · 0.90
updateCachedFunction · 0.90
typedNodeEntryFunction · 0.90
defineTaskFunction · 0.85
fetchNodeFunction · 0.85
forwardAllOutputsFunction · 0.85
saveAndForwardFunction · 0.85

Tested by

no test coverage detected