Skip to content

Commit ab40de9

Browse files
committed
fix parallel running issue
1 parent 6ba4ecf commit ab40de9

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/taskmaster.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import {Connection} from 'amqplib/callback_api'
55
import { execute } from './tasks'
66
import config = require('../config.js')
77
import { SubmitJob, RunJob } from 'tasks/job';
8+
import { mkdir } from 'shelljs'
89

910
// =============== Setup Raven
1011
Raven.config(config.SENTRY.DSN, {
@@ -17,6 +18,8 @@ Raven.config(config.SENTRY.DSN, {
1718
let jobQ = 'job_queue'
1819
let successQ = 'success_queue'
1920

21+
mkdir('-p', config.RUNBOX.DIR)
22+
2023
amqp.connect(`amqp://${config.AMQP.USER}:${config.AMQP.PASS}@${config.AMQP.HOST}:${config.AMQP.PORT}`, (err, connection: Connection) => {
2124
if (err) throw err
2225

src/tasks/index.ts

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,6 @@ export function execute(job: RunJob): Promise<RunResult>
1111
export function execute(job: SubmitJob): Promise<SubmissionResult>
1212
export async function execute (job: Job) {
1313
// Create RUNBOX
14-
rm('-rf', config.RUNBOX.DIR)
15-
mkdir('-p', config.RUNBOX.DIR)
1614
const currentJobDir = path.join(config.RUNBOX.DIR, job.id.toString())
1715
mkdir('-p', currentJobDir)
1816

0 commit comments

Comments
 (0)