Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
girl-loves-coding committed Oct 8, 2024
1 parent 903efd5 commit 908076a
Show file tree
Hide file tree
Showing 4 changed files with 3 additions and 106 deletions.
36 changes: 0 additions & 36 deletions examples/using-database-plugin.ts

This file was deleted.

67 changes: 0 additions & 67 deletions examples/workflow.json

This file was deleted.

4 changes: 2 additions & 2 deletions packages/execution-engine/src/ExecutionEngine.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ import { IExecutionResult } from "@data-river/shared/interfaces/IExecutionResult
import { VariableResolver } from "./VariableResolver";
import { IExecutionStrategy } from "./strategies/IExecutionStrategy";
import { ILogger } from "@data-river/shared/interfaces/ILogger";
import { forEach } from "lodash";

@injectable()
export class ExecutionEngine {
Expand Down Expand Up @@ -244,6 +243,8 @@ export class ExecutionEngine {
): {
errors: Error[];
} {
this.logger.error(`Error in block ${blockConfig.id}:`, error);

if (blockConfig.onError) {
try {
blockConfig.onError(error, blockConfig);
Expand All @@ -255,7 +256,6 @@ export class ExecutionEngine {
return { errors: [error as Error] };
}
}
this.logger.error(`Error in block ${blockConfig.id}:`, error);

return { errors: [error] };
}
Expand Down
2 changes: 1 addition & 1 deletion packages/shared/src/utils/logger/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ export default class DefaultLogger implements ILogger {

group(message: string): void {
if (this.shouldLog("info")) {
console.group(chalk.bold(message)); // Using console.group for grouping
console.group(chalk.bold(message));
}
}

Expand Down

0 comments on commit 908076a

Please sign in to comment.