Method tryJobStep

packages/backend/src/models/JobModel/JobModel.ts:175–202

(
        jobUuid: string,
        jobStepType: JobStepType,
        callback: () => Promise<T>,
    )

    }

    async tryJobStep<T>(
        jobUuid: string,
        jobStepType: JobStepType,
        callback: () => Promise<T>,
    ): Promise<T> {
        try {
            await this.startJobStep(jobUuid, jobStepType);

            const result = await callback();

            await this.updateJobStep(
                jobUuid,
                JobStepStatusType.DONE,
                jobStepType,
            );
            return result;
        } catch (e) {
            await this.updateJobStep(
                jobUuid,
                JobStepStatusType.ERROR,
                jobStepType,
                getErrorMessage(e),
                e instanceof DbtError ? e.logs : [],
            );
            await this.update(jobUuid, { jobStatus: JobStatusType.ERROR });
            throw e; // throw the error again
        }
    }
}