jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

update logs to new format

Browse source
This commit is contained in:
anovazzi1 2024-06-14 17:10:50 -03:00
commit 49db8a847c
2 changed files with 14 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/frontend/src/CustomNodes/GenericNode/components/outputModal/components/switchOutputView/index.tsx
View file

@ -25,7 +25,7 @@ const SwitchOutputView: React.FC<SwitchOutputViewProps> = ({
const flowPoolNode = (flowPool[nodeId] ?? [])[ const flowPoolNode = (flowPool[nodeId] ?? [])[
(flowPool[nodeId]?.length ?? 1) - 1 (flowPool[nodeId]?.length ?? 1) - 1
]; ];
let results = flowPoolNode?.data?.logs[outputName] ?? ""; let results = (flowPoolNode?.data?.logs[outputName] ?? [])[0] ?? "";
if (Array.isArray(results)) { if (Array.isArray(results)) {
console.error("Log results are an array", results); console.error("Log results are an array", results);
return; return;

26
src/frontend/src/CustomNodes/GenericNode/components/parameterComponent/index.tsx
View file

@ -91,7 +91,7 @@ export default function ParameterComponent({
const logHasMessage = (data: any) => { const logHasMessage = (data: any) => {
if (!outputName) return; if (!outputName) return;
const logs = data?.logs[outputName]; const logs = (data?.logs[outputName] ?? [])[0];
if (Array.isArray(logs) && logs.length > 1) { if (Array.isArray(logs) && logs.length > 1) {
return logs.some((log) => log.message); return logs.some((log) => log.message);
} else { } else {
@ -101,7 +101,7 @@ export default function ParameterComponent({
const logTypeIsUnknown = (data: any) => { const logTypeIsUnknown = (data: any) => {
if (!outputName) return; if (!outputName) return;
const logs = data?.logs[outputName]; const logs = (data?.logs[outputName] ?? [])[0];
if (Array.isArray(logs) && logs.length > 1) { if (Array.isArray(logs) && logs.length > 1) {
return logs.some((log) => log.type === "unknown"); return logs.some((log) => log.type === "unknown");
} else { } else {
@ -119,7 +119,7 @@ export default function ParameterComponent({
let hasOutputs; let hasOutputs;
if (flowPoolNode?.data?.logs && outputName) { if (flowPoolNode?.data?.logs && outputName) {
hasOutputs = flowPoolNode?.data?.logs[outputName] ?? null; hasOutputs = (flowPoolNode?.data?.logs[outputName] ?? [])[0] ?? null;
} }
const unknownOutput = logTypeIsUnknown(flowPoolNode?.data); const unknownOutput = logTypeIsUnknown(flowPoolNode?.data);
@ -144,7 +144,7 @@ export default function ParameterComponent({
handleUpdateValues, handleUpdateValues,
debouncedHandleUpdateValues, debouncedHandleUpdateValues,
setNode, setNode,
setIsLoading setIsLoading,
); );
const { handleNodeClass: handleNodeClassHook } = useHandleNodeClass( const { handleNodeClass: handleNodeClassHook } = useHandleNodeClass(
@ -152,7 +152,7 @@ export default function ParameterComponent({
name, name,
takeSnapshot, takeSnapshot,
setNode, setNode,
updateNodeInternals updateNodeInternals,
); );
const { handleRefreshButtonPress: handleRefreshButtonPressHook } = const { handleRefreshButtonPress: handleRefreshButtonPressHook } =
@ -161,13 +161,13 @@ export default function ParameterComponent({
let disabled = let disabled =
edges.some( edges.some(
(edge) => (edge) =>
edge.targetHandle === scapedJSONStringfy(proxy ? { ...id, proxy } : id) edge.targetHandle === scapedJSONStringfy(proxy ? { ...id, proxy } : id),
) ?? false; ) ?? false;
let disabledOutput = let disabledOutput =
edges.some( edges.some(
(edge) => (edge) =>
edge.sourceHandle === scapedJSONStringfy(proxy ? { ...id, proxy } : id) edge.sourceHandle === scapedJSONStringfy(proxy ? { ...id, proxy } : id),
) ?? false; ) ?? false;
const handleRefreshButtonPress = async (name, data) => { const handleRefreshButtonPress = async (name, data) => {
@ -178,7 +178,7 @@ export default function ParameterComponent({
const handleOnNewValue = async ( const handleOnNewValue = async (
newValue: string | string[] | boolean | Object[], newValue: string | string[] | boolean | Object[],
skipSnapshot: boolean | undefined = false skipSnapshot: boolean | undefined = false,
): Promise<void> => { ): Promise<void> => {
handleOnNewValueHook(newValue, skipSnapshot); handleOnNewValueHook(newValue, skipSnapshot);
}; };
@ -292,14 +292,14 @@ export default function ParameterComponent({
className={classNames( className={classNames(
left ? "my-12 -ml-0.5 " : " my-12 -mr-0.5 ", left ? "my-12 -ml-0.5 " : " my-12 -mr-0.5 ",
"h-3 w-3 rounded-full border-2 bg-background", "h-3 w-3 rounded-full border-2 bg-background",
!showNode ? "mt-0" : "" !showNode ? "mt-0" : "",
)} )}
style={{ style={{
borderColor: color ?? nodeColors.unknown, borderColor: color ?? nodeColors.unknown,
}} }}
onClick={() => { onClick={() => {
setFilterEdge( setFilterEdge(
groupByFamily(myData, tooltipTitle!, left, nodes!) groupByFamily(myData, tooltipTitle!, left, nodes!),
); );
}} }}
></Handle> ></Handle>
@ -379,7 +379,7 @@ export default function ParameterComponent({
"h-5 w-5 rounded-md", "h-5 w-5 rounded-md",
displayOutputPreview && !unknownOutput displayOutputPreview && !unknownOutput
? " hover:text-medium-indigo" ? " hover:text-medium-indigo"
: " cursor-not-allowed text-muted-foreground" : " cursor-not-allowed text-muted-foreground",
)} )}
name={"ScanEye"} name={"ScanEye"}
/> />
@ -436,12 +436,12 @@ export default function ParameterComponent({
} }
className={classNames( className={classNames(
left ? "-ml-0.5" : "-mr-0.5", left ? "-ml-0.5" : "-mr-0.5",
"h-3 w-3 rounded-full border-2 bg-background" "h-3 w-3 rounded-full border-2 bg-background",
)} )}
style={{ borderColor: color ?? nodeColors.unknown }} style={{ borderColor: color ?? nodeColors.unknown }}
onClick={() => { onClick={() => {
setFilterEdge( setFilterEdge(
groupByFamily(myData, tooltipTitle!, left, nodes!) groupByFamily(myData, tooltipTitle!, left, nodes!),
); );
}} }}
/> />