if (ev->any.type == EDG_WLL_EVENT_REGJOB &&
(ev->regJob.jobtype == EDG_WLL_REGJOB_DAG ||
ev->regJob.jobtype == EDG_WLL_REGJOB_PARTITIONED ||
- ev->regJob.jobtype == EDG_WLL_REGJOB_COLLECTION /*||
- ev->regJob.jobtype == EDG_WLL_REGJOB_FILE_TRANSFER_COLLECTION*/) &&
+ ev->regJob.jobtype == EDG_WLL_REGJOB_COLLECTION ||
+ ev->regJob.jobtype == EDG_WLL_REGJOB_FILE_TRANSFER_COLLECTION) &&
ev->regJob.nsubjobs > 0) {
if (register_subjobs_embryonic(ctx,&ev->regJob)) goto rollback;
edg_wlc_JobIdDup(e->jobId, &intJobStat_to_JobStat(stat)->parent_job)) goto err;
intJobStat_to_JobStat(stat)->state = EDG_WLL_JOB_SUBMITTED;
intJobStat_to_JobStat(stat)->owner = strdup(e->user);
- intJobStat_to_JobStat(stat)->jobtype = EDG_WLL_STAT_SIMPLE;
+ intJobStat_to_JobStat(stat)->jobtype = e->jobtype;
intJobStat_to_JobStat(stat)->stateEnterTimes[1 + EDG_WLL_JOB_SUBMITTED] = (int)e->timestamp.tv_sec;
intJobStat_to_JobStat(stat)->lastUpdateTime = e->timestamp;
intJobStat_to_JobStat(stat)->stateEnterTime = e->timestamp;