fix: merge conflict
This commit is contained in:
@@ -550,17 +550,15 @@ export class WorkflowInterpreter {
|
|||||||
},
|
},
|
||||||
serializableCallback: async (data: any) => {
|
serializableCallback: async (data: any) => {
|
||||||
try {
|
try {
|
||||||
if (!this.currentActionType || !this.currentActionName) return;
|
if (!data || typeof data !== "object") return;
|
||||||
|
|
||||||
let typeKey = this.currentActionType;
|
let typeKey = this.currentActionType || "";
|
||||||
let actionName = this.currentActionName;
|
|
||||||
|
|
||||||
let subtree =
|
if (this.currentActionType === "scrapeList") {
|
||||||
typeKey === "scrapeList"
|
typeKey = "scrapeList";
|
||||||
? data?.scrapeList
|
} else if (this.currentActionType === "scrapeSchema") {
|
||||||
: typeKey === "scrapeSchema"
|
typeKey = "scrapeSchema";
|
||||||
? data?.scrapeSchema
|
}
|
||||||
: null;
|
|
||||||
|
|
||||||
if (typeKey === "scrapeList" && data.scrapeList) {
|
if (typeKey === "scrapeList" && data.scrapeList) {
|
||||||
data = data.scrapeList;
|
data = data.scrapeList;
|
||||||
@@ -612,7 +610,7 @@ export class WorkflowInterpreter {
|
|||||||
data: flattened,
|
data: flattened,
|
||||||
});
|
});
|
||||||
} catch (err: any) {
|
} catch (err: any) {
|
||||||
logger.log("error", `serializableCallback failed: ${err.message}`);
|
logger.log('error', `serializableCallback handler failed: ${err.message}`);
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
binaryCallback: async (payload: { name: string; data: Buffer; mimeType: string }) => {
|
binaryCallback: async (payload: { name: string; data: Buffer; mimeType: string }) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user