You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

895 lines
23KB

  1. import "./tasks/mapping.wdl" as mapping
  2. import "./tasks/Dedup.wdl" as Dedup
  3. import "./tasks/qualimap.wdl" as qualimap
  4. import "./tasks/deduped_Metrics.wdl" as deduped_Metrics
  5. import "./tasks/sentieon.wdl" as sentieon
  6. import "./tasks/Realigner.wdl" as Realigner
  7. import "./tasks/BQSR.wdl" as BQSR
  8. import "./tasks/Haplotyper.wdl" as Haplotyper
  9. import "./tasks/benchmark.wdl" as benchmark
  10. import "./tasks/multiqc.wdl" as multiqc
  11. import "./tasks/multiqc_hap.wdl" as multiqc_hap
  12. import "./tasks/merge_sentieon_metrics.wdl" as merge_sentieon_metrics
  13. import "./tasks/extract_tables.wdl" as extract_tables
  14. import "./tasks/extract_tables_vcf.wdl" as extract_tables_vcf
  15. import "./tasks/mendelian.wdl" as mendelian
  16. import "./tasks/merge_mendelian.wdl" as merge_mendelian
  17. import "./tasks/quartet_mendelian.wdl" as quartet_mendelian
  18. import "./tasks/fastqc.wdl" as fastqc
  19. import "./tasks/fastqscreen.wdl" as fastqscreen
  20. import "./tasks/merge_family.wdl" as merge_family
  21. import "./tasks/filter_vcf.wdl" as filter_vcf
  22. workflow {{ project_name }} {
  23. File? fastq_1_D5
  24. File? fastq_1_D6
  25. File? fastq_1_F7
  26. File? fastq_1_M8
  27. File? fastq_2_D5
  28. File? fastq_2_D6
  29. File? fastq_2_F7
  30. File? fastq_2_M8
  31. File? vcf_D5
  32. File? vcf_D6
  33. File? vcf_F7
  34. File? vcf_M8
  35. String SENTIEON_INSTALL_DIR
  36. String SENTIEON_LICENSE
  37. String SENTIEONdocker
  38. String FASTQCdocker
  39. String FASTQSCREENdocker
  40. String QUALIMAPdocker
  41. String BENCHMARKdocker
  42. String MENDELIANdocker
  43. String DIYdocker
  44. String MULTIQCdocker
  45. String BEDTOOLSdocker
  46. String fasta
  47. File ref_dir
  48. File dbmills_dir
  49. String db_mills
  50. File dbsnp_dir
  51. String dbsnp
  52. File screen_ref_dir
  53. File fastq_screen_conf
  54. File benchmarking_dir
  55. String project
  56. String disk_size
  57. String BIGcluster_config
  58. String SMALLcluster_config
  59. if (fastq_1_D5!= "") {
  60. call mapping.mapping as mapping_D5 {
  61. input:
  62. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  63. SENTIEON_LICENSE=SENTIEON_LICENSE,
  64. group="LCL5",
  65. sample="LCL5",
  66. pl="ILLUMINAL",
  67. fasta=fasta,
  68. ref_dir=ref_dir,
  69. fastq_1=fastq_1_D5,
  70. fastq_2=fastq_2_D5,
  71. docker=SENTIEONdocker,
  72. disk_size=disk_size,
  73. cluster_config=BIGcluster_config
  74. }
  75. call fastqc.fastqc as fastqc_D5 {
  76. input:
  77. read1=fastq_1_D5,
  78. read2=fastq_2_D5,
  79. docker=FASTQCdocker,
  80. cluster_config=BIGcluster_config,
  81. disk_size=disk_size
  82. }
  83. call fastqscreen.fastq_screen as fastqscreen_D5 {
  84. input:
  85. read1=fastq_1_D5,
  86. read2=fastq_2_D5,
  87. screen_ref_dir=screen_ref_dir,
  88. fastq_screen_conf=fastq_screen_conf,
  89. docker=FASTQSCREENdocker,
  90. cluster_config=BIGcluster_config,
  91. disk_size=disk_size
  92. }
  93. call Dedup.Dedup as Dedup_D5 {
  94. input:
  95. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  96. sorted_bam=mapping_D5.sorted_bam,
  97. sorted_bam_index=mapping_D5.sorted_bam_index,
  98. sample="LCL5",
  99. docker=SENTIEONdocker,
  100. disk_size=disk_size,
  101. cluster_config=BIGcluster_config
  102. }
  103. call qualimap.qualimap as qualimap_D5 {
  104. input:
  105. bam=Dedup_D5.Dedup_bam,
  106. bai=Dedup_D5.Dedup_bam_index,
  107. docker=QUALIMAPdocker,
  108. disk_size=disk_size,
  109. cluster_config=BIGcluster_config
  110. }
  111. call deduped_Metrics.deduped_Metrics as deduped_Metrics_D5 {
  112. input:
  113. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  114. fasta=fasta,
  115. ref_dir=ref_dir,
  116. Dedup_bam=Dedup_D5.Dedup_bam,
  117. Dedup_bam_index=Dedup_D5.Dedup_bam_index,
  118. sample="LCL5",
  119. docker=SENTIEONdocker,
  120. disk_size=disk_size,
  121. cluster_config=BIGcluster_config
  122. }
  123. call sentieon.sentieon as sentieon_D5 {
  124. input:
  125. quality_yield=deduped_Metrics_D5.deduped_QualityYield,
  126. wgs_metrics_algo=deduped_Metrics_D5.deduped_wgsmetrics,
  127. aln_metrics=deduped_Metrics_D5.dedeuped_aln_metrics,
  128. is_metrics=deduped_Metrics_D5.deduped_is_metrics,
  129. sample="LCL5",
  130. docker=SENTIEONdocker,
  131. cluster_config=SMALLcluster_config,
  132. disk_size=disk_size
  133. }
  134. call Realigner.Realigner as Realigner_D5 {
  135. input:
  136. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  137. fasta=fasta,
  138. ref_dir=ref_dir,
  139. Dedup_bam=Dedup_D5.Dedup_bam,
  140. Dedup_bam_index=Dedup_D5.Dedup_bam_index,
  141. db_mills=db_mills,
  142. dbmills_dir=dbmills_dir,
  143. sample="LCL5",
  144. docker=SENTIEONdocker,
  145. disk_size=disk_size,
  146. cluster_config=BIGcluster_config
  147. }
  148. call BQSR.BQSR as BQSR_D5 {
  149. input:
  150. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  151. fasta=fasta,
  152. ref_dir=ref_dir,
  153. realigned_bam=Realigner_D5.realigner_bam,
  154. realigned_bam_index=Realigner_D5.realigner_bam_index,
  155. db_mills=db_mills,
  156. dbmills_dir=dbmills_dir,
  157. dbsnp=dbsnp,
  158. dbsnp_dir=dbsnp_dir,
  159. sample="LCL5",
  160. docker=SENTIEONdocker,
  161. disk_size=disk_size,
  162. cluster_config=BIGcluster_config
  163. }
  164. call Haplotyper.Haplotyper as Haplotyper_D5 {
  165. input:
  166. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  167. fasta=fasta,
  168. ref_dir=ref_dir,
  169. recaled_bam=BQSR_D5.recaled_bam,
  170. recaled_bam_index=BQSR_D5.recaled_bam_index,
  171. sample="LCL5",
  172. docker=SENTIEONdocker,
  173. disk_size=disk_size,
  174. cluster_config=BIGcluster_config
  175. }
  176. call filter_vcf.filter_vcf as filter_vcf_D5 {
  177. input:
  178. vcf=Haplotyper_D5.vcf,
  179. docker=BEDTOOLSdocker,
  180. cluster_config=SMALLcluster_config,
  181. disk_size=disk_size
  182. }
  183. call benchmark.benchmark as benchmark_D5 {
  184. input:
  185. filtered_vcf=filter_vcf_D5.filtered_vcf,
  186. benchmarking_dir=benchmarking_dir,
  187. ref_dir=ref_dir,
  188. fasta=fasta,
  189. docker=BENCHMARKdocker,
  190. cluster_config=BIGcluster_config,
  191. disk_size=disk_size
  192. }
  193. call mapping.mapping as mapping_D6 {
  194. input:
  195. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  196. SENTIEON_LICENSE=SENTIEON_LICENSE,
  197. group="LCL6",
  198. sample="LCL6",
  199. pl="ILLUMINAL",
  200. fasta=fasta,
  201. ref_dir=ref_dir,
  202. fastq_1=fastq_1_D6,
  203. fastq_2=fastq_2_D6,
  204. docker=SENTIEONdocker,
  205. disk_size=disk_size,
  206. cluster_config=BIGcluster_config
  207. }
  208. call fastqc.fastqc as fastqc_D6 {
  209. input:
  210. read1=fastq_1_D6,
  211. read2=fastq_2_D6,
  212. docker=FASTQCdocker,
  213. cluster_config=BIGcluster_config,
  214. disk_size=disk_size
  215. }
  216. call fastqscreen.fastq_screen as fastqscreen_D6 {
  217. input:
  218. read1=fastq_1_D6,
  219. read2=fastq_2_D6,
  220. screen_ref_dir=screen_ref_dir,
  221. fastq_screen_conf=fastq_screen_conf,
  222. docker=FASTQSCREENdocker,
  223. cluster_config=BIGcluster_config,
  224. disk_size=disk_size
  225. }
  226. call Dedup.Dedup as Dedup_D6 {
  227. input:
  228. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  229. sorted_bam=mapping_D6.sorted_bam,
  230. sorted_bam_index=mapping_D6.sorted_bam_index,
  231. sample="LCL6",
  232. docker=SENTIEONdocker,
  233. disk_size=disk_size,
  234. cluster_config=BIGcluster_config
  235. }
  236. call qualimap.qualimap as qualimap_D6 {
  237. input:
  238. bam=Dedup_D6.Dedup_bam,
  239. bai=Dedup_D6.Dedup_bam_index,
  240. docker=QUALIMAPdocker,
  241. disk_size=disk_size,
  242. cluster_config=BIGcluster_config
  243. }
  244. call deduped_Metrics.deduped_Metrics as deduped_Metrics_D6 {
  245. input:
  246. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  247. fasta=fasta,
  248. ref_dir=ref_dir,
  249. Dedup_bam=Dedup_D6.Dedup_bam,
  250. Dedup_bam_index=Dedup_D6.Dedup_bam_index,
  251. sample="LCL6",
  252. docker=SENTIEONdocker,
  253. disk_size=disk_size,
  254. cluster_config=BIGcluster_config
  255. }
  256. call sentieon.sentieon as sentieon_D6 {
  257. input:
  258. quality_yield=deduped_Metrics_D6.deduped_QualityYield,
  259. wgs_metrics_algo=deduped_Metrics_D6.deduped_wgsmetrics,
  260. aln_metrics=deduped_Metrics_D6.dedeuped_aln_metrics,
  261. is_metrics=deduped_Metrics_D6.deduped_is_metrics,
  262. sample="LCL6",
  263. docker=SENTIEONdocker,
  264. cluster_config=SMALLcluster_config,
  265. disk_size=disk_size
  266. }
  267. call Realigner.Realigner as Realigner_D6 {
  268. input:
  269. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  270. fasta=fasta,
  271. ref_dir=ref_dir,
  272. Dedup_bam=Dedup_D6.Dedup_bam,
  273. Dedup_bam_index=Dedup_D6.Dedup_bam_index,
  274. db_mills=db_mills,
  275. dbmills_dir=dbmills_dir,
  276. sample="LCL6",
  277. docker=SENTIEONdocker,
  278. disk_size=disk_size,
  279. cluster_config=BIGcluster_config
  280. }
  281. call BQSR.BQSR as BQSR_D6 {
  282. input:
  283. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  284. fasta=fasta,
  285. ref_dir=ref_dir,
  286. realigned_bam=Realigner_D6.realigner_bam,
  287. realigned_bam_index=Realigner_D6.realigner_bam_index,
  288. db_mills=db_mills,
  289. dbmills_dir=dbmills_dir,
  290. dbsnp=dbsnp,
  291. dbsnp_dir=dbsnp_dir,
  292. sample="LCL6",
  293. docker=SENTIEONdocker,
  294. disk_size=disk_size,
  295. cluster_config=BIGcluster_config
  296. }
  297. call Haplotyper.Haplotyper as Haplotyper_D6 {
  298. input:
  299. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  300. fasta=fasta,
  301. ref_dir=ref_dir,
  302. recaled_bam=BQSR_D6.recaled_bam,
  303. recaled_bam_index=BQSR_D6.recaled_bam_index,
  304. sample="LCL6",
  305. docker=SENTIEONdocker,
  306. disk_size=disk_size,
  307. cluster_config=BIGcluster_config
  308. }
  309. call filter_vcf.filter_vcf as filter_vcf_D6 {
  310. input:
  311. vcf=Haplotyper_D6.vcf,
  312. docker=BEDTOOLSdocker,
  313. cluster_config=SMALLcluster_config,
  314. disk_size=disk_size
  315. }
  316. call benchmark.benchmark as benchmark_D6 {
  317. input:
  318. filtered_vcf=filter_vcf_D6.filtered_vcf,
  319. benchmarking_dir=benchmarking_dir,
  320. ref_dir=ref_dir,
  321. fasta=fasta,
  322. docker=BENCHMARKdocker,
  323. cluster_config=BIGcluster_config,
  324. disk_size=disk_size
  325. }
  326. call mapping.mapping as mapping_F7 {
  327. input:
  328. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  329. SENTIEON_LICENSE=SENTIEON_LICENSE,
  330. group="LCL7",
  331. sample="LCL7",
  332. pl="ILLUMINAL",
  333. fasta=fasta,
  334. ref_dir=ref_dir,
  335. fastq_1=fastq_1_F7,
  336. fastq_2=fastq_2_F7,
  337. docker=SENTIEONdocker,
  338. disk_size=disk_size,
  339. cluster_config=BIGcluster_config
  340. }
  341. call fastqc.fastqc as fastqc_F7 {
  342. input:
  343. read1=fastq_1_F7,
  344. read2=fastq_2_F7,
  345. docker=FASTQCdocker,
  346. cluster_config=BIGcluster_config,
  347. disk_size=disk_size
  348. }
  349. call fastqscreen.fastq_screen as fastqscreen_F7 {
  350. input:
  351. read1=fastq_1_F7,
  352. read2=fastq_2_F7,
  353. screen_ref_dir=screen_ref_dir,
  354. fastq_screen_conf=fastq_screen_conf,
  355. docker=FASTQSCREENdocker,
  356. cluster_config=BIGcluster_config,
  357. disk_size=disk_size
  358. }
  359. call Dedup.Dedup as Dedup_F7 {
  360. input:
  361. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  362. sorted_bam=mapping_F7.sorted_bam,
  363. sorted_bam_index=mapping_F7.sorted_bam_index,
  364. sample="LCL7",
  365. docker=SENTIEONdocker,
  366. disk_size=disk_size,
  367. cluster_config=BIGcluster_config
  368. }
  369. call qualimap.qualimap as qualimap_F7 {
  370. input:
  371. bam=Dedup_F7.Dedup_bam,
  372. bai=Dedup_F7.Dedup_bam_index,
  373. docker=QUALIMAPdocker,
  374. disk_size=disk_size,
  375. cluster_config=BIGcluster_config
  376. }
  377. call deduped_Metrics.deduped_Metrics as deduped_Metrics_F7 {
  378. input:
  379. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  380. fasta=fasta,
  381. ref_dir=ref_dir,
  382. Dedup_bam=Dedup_F7.Dedup_bam,
  383. Dedup_bam_index=Dedup_F7.Dedup_bam_index,
  384. sample="LCL7",
  385. docker=SENTIEONdocker,
  386. disk_size=disk_size,
  387. cluster_config=BIGcluster_config
  388. }
  389. call sentieon.sentieon as sentieon_F7 {
  390. input:
  391. quality_yield=deduped_Metrics_F7.deduped_QualityYield,
  392. wgs_metrics_algo=deduped_Metrics_F7.deduped_wgsmetrics,
  393. aln_metrics=deduped_Metrics_F7.dedeuped_aln_metrics,
  394. is_metrics=deduped_Metrics_F7.deduped_is_metrics,
  395. sample="LCL7",
  396. docker=SENTIEONdocker,
  397. cluster_config=SMALLcluster_config,
  398. disk_size=disk_size
  399. }
  400. call Realigner.Realigner as Realigner_F7 {
  401. input:
  402. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  403. fasta=fasta,
  404. ref_dir=ref_dir,
  405. Dedup_bam=Dedup_F7.Dedup_bam,
  406. Dedup_bam_index=Dedup_F7.Dedup_bam_index,
  407. db_mills=db_mills,
  408. dbmills_dir=dbmills_dir,
  409. sample="LCL7",
  410. docker=SENTIEONdocker,
  411. disk_size=disk_size,
  412. cluster_config=BIGcluster_config
  413. }
  414. call BQSR.BQSR as BQSR_F7 {
  415. input:
  416. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  417. fasta=fasta,
  418. ref_dir=ref_dir,
  419. realigned_bam=Realigner_F7.realigner_bam,
  420. realigned_bam_index=Realigner_F7.realigner_bam_index,
  421. db_mills=db_mills,
  422. dbmills_dir=dbmills_dir,
  423. dbsnp=dbsnp,
  424. dbsnp_dir=dbsnp_dir,
  425. sample="LCL7",
  426. docker=SENTIEONdocker,
  427. disk_size=disk_size,
  428. cluster_config=BIGcluster_config
  429. }
  430. call Haplotyper.Haplotyper as Haplotyper_F7 {
  431. input:
  432. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  433. fasta=fasta,
  434. ref_dir=ref_dir,
  435. recaled_bam=BQSR_F7.recaled_bam,
  436. recaled_bam_index=BQSR_F7.recaled_bam_index,
  437. sample="LCL7",
  438. docker=SENTIEONdocker,
  439. disk_size=disk_size,
  440. cluster_config=BIGcluster_config
  441. }
  442. call filter_vcf.filter_vcf as filter_vcf_F7 {
  443. input:
  444. vcf=Haplotyper_F7.vcf,
  445. docker=BEDTOOLSdocker,
  446. cluster_config=SMALLcluster_config,
  447. disk_size=disk_size
  448. }
  449. call benchmark.benchmark as benchmark_F7 {
  450. input:
  451. filtered_vcf=filter_vcf_F7.filtered_vcf,
  452. benchmarking_dir=benchmarking_dir,
  453. ref_dir=ref_dir,
  454. fasta=fasta,
  455. docker=BENCHMARKdocker,
  456. cluster_config=BIGcluster_config,
  457. disk_size=disk_size
  458. }
  459. call mapping.mapping as mapping_M8 {
  460. input:
  461. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  462. SENTIEON_LICENSE=SENTIEON_LICENSE,
  463. group="LCL8",
  464. sample="LCL8",
  465. pl="ILLUMINAL",
  466. fasta=fasta,
  467. ref_dir=ref_dir,
  468. fastq_1=fastq_1_M8,
  469. fastq_2=fastq_2_M8,
  470. docker=SENTIEONdocker,
  471. disk_size=disk_size,
  472. cluster_config=BIGcluster_config
  473. }
  474. call fastqc.fastqc as fastqc_M8 {
  475. input:
  476. read1=fastq_1_M8,
  477. read2=fastq_2_M8,
  478. docker=FASTQCdocker,
  479. cluster_config=BIGcluster_config,
  480. disk_size=disk_size
  481. }
  482. call fastqscreen.fastq_screen as fastqscreen_M8 {
  483. input:
  484. read1=fastq_1_M8,
  485. read2=fastq_2_M8,
  486. screen_ref_dir=screen_ref_dir,
  487. fastq_screen_conf=fastq_screen_conf,
  488. docker=FASTQSCREENdocker,
  489. cluster_config=BIGcluster_config,
  490. disk_size=disk_size
  491. }
  492. call Dedup.Dedup as Dedup_M8 {
  493. input:
  494. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  495. sorted_bam=mapping_M8.sorted_bam,
  496. sorted_bam_index=mapping_M8.sorted_bam_index,
  497. sample="LCL8",
  498. docker=SENTIEONdocker,
  499. disk_size=disk_size,
  500. cluster_config=BIGcluster_config
  501. }
  502. call qualimap.qualimap as qualimap_M8 {
  503. input:
  504. bam=Dedup_M8.Dedup_bam,
  505. bai=Dedup_M8.Dedup_bam_index,
  506. docker=QUALIMAPdocker,
  507. disk_size=disk_size,
  508. cluster_config=BIGcluster_config
  509. }
  510. call deduped_Metrics.deduped_Metrics as deduped_Metrics_M8 {
  511. input:
  512. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  513. fasta=fasta,
  514. ref_dir=ref_dir,
  515. Dedup_bam=Dedup_M8.Dedup_bam,
  516. Dedup_bam_index=Dedup_M8.Dedup_bam_index,
  517. sample="LCL8",
  518. docker=SENTIEONdocker,
  519. disk_size=disk_size,
  520. cluster_config=BIGcluster_config
  521. }
  522. call sentieon.sentieon as sentieon_M8 {
  523. input:
  524. quality_yield=deduped_Metrics_M8.deduped_QualityYield,
  525. wgs_metrics_algo=deduped_Metrics_M8.deduped_wgsmetrics,
  526. aln_metrics=deduped_Metrics_M8.dedeuped_aln_metrics,
  527. is_metrics=deduped_Metrics_M8.deduped_is_metrics,
  528. sample="LCL8",
  529. docker=SENTIEONdocker,
  530. cluster_config=SMALLcluster_config,
  531. disk_size=disk_size
  532. }
  533. call Realigner.Realigner as Realigner_M8 {
  534. input:
  535. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  536. fasta=fasta,
  537. ref_dir=ref_dir,
  538. Dedup_bam=Dedup_M8.Dedup_bam,
  539. Dedup_bam_index=Dedup_M8.Dedup_bam_index,
  540. db_mills=db_mills,
  541. dbmills_dir=dbmills_dir,
  542. sample="LCL8",
  543. docker=SENTIEONdocker,
  544. disk_size=disk_size,
  545. cluster_config=BIGcluster_config
  546. }
  547. call BQSR.BQSR as BQSR_M8 {
  548. input:
  549. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  550. fasta=fasta,
  551. ref_dir=ref_dir,
  552. realigned_bam=Realigner_M8.realigner_bam,
  553. realigned_bam_index=Realigner_M8.realigner_bam_index,
  554. db_mills=db_mills,
  555. dbmills_dir=dbmills_dir,
  556. dbsnp=dbsnp,
  557. dbsnp_dir=dbsnp_dir,
  558. sample="LCL8",
  559. docker=SENTIEONdocker,
  560. disk_size=disk_size,
  561. cluster_config=BIGcluster_config
  562. }
  563. call Haplotyper.Haplotyper as Haplotyper_M8 {
  564. input:
  565. SENTIEON_INSTALL_DIR=SENTIEON_INSTALL_DIR,
  566. fasta=fasta,
  567. ref_dir=ref_dir,
  568. recaled_bam=BQSR_M8.recaled_bam,
  569. recaled_bam_index=BQSR_M8.recaled_bam_index,
  570. sample="LCL8",
  571. docker=SENTIEONdocker,
  572. disk_size=disk_size,
  573. cluster_config=BIGcluster_config
  574. }
  575. call filter_vcf.filter_vcf as filter_vcf_M8 {
  576. input:
  577. vcf=Haplotyper_M8.vcf,
  578. docker=BEDTOOLSdocker,
  579. cluster_config=SMALLcluster_config,
  580. disk_size=disk_size
  581. }
  582. call benchmark.benchmark as benchmark_M8 {
  583. input:
  584. filtered_vcf=filter_vcf_M8.filtered_vcf,
  585. benchmarking_dir=benchmarking_dir,
  586. ref_dir=ref_dir,
  587. fasta=fasta,
  588. docker=BENCHMARKdocker,
  589. cluster_config=BIGcluster_config,
  590. disk_size=disk_size
  591. }
  592. Array[File] fastqc_read1_zip = [fastqc_D5.read1_zip, fastqc_D6.read1_zip, fastqc_F7.read1_zip, fastqc_M8.read1_zip]
  593. Array[File] fastqc_read2_zip = [fastqc_D5.read2_zip, fastqc_D6.read2_zip, fastqc_F7.read2_zip, fastqc_M8.read2_zip]
  594. Array[File] fastqscreen_txt1 = [fastqscreen_D5.txt1, fastqscreen_D6.txt1, fastqscreen_F7.txt1, fastqscreen_M8.txt1]
  595. Array[File] fastqscreen_txt2 = [fastqscreen_D5.txt2, fastqscreen_D6.txt2, fastqscreen_F7.txt2, fastqscreen_M8.txt2]
  596. Array[File] benchmark_summary = [benchmark_D5.summary, benchmark_D6.summary, benchmark_F7.summary, benchmark_M8.summary]
  597. call multiqc.multiqc as multiqc_big {
  598. input:
  599. read1_zip=fastqc_read1_zip,
  600. read2_zip=fastqc_read2_zip,
  601. txt1=fastqscreen_txt1,
  602. txt2=fastqscreen_txt2,
  603. summary=benchmark_summary,
  604. docker=MULTIQCdocker,
  605. cluster_config=SMALLcluster_config,
  606. disk_size=disk_size
  607. }
  608. Array[File] sentieon_quality_yield_header = [sentieon_D5.quality_yield_header, sentieon_D6.quality_yield_header, sentieon_F7.quality_yield_header, sentieon_M8.quality_yield_header]
  609. Array[File] sentieon_wgs_metrics_algo_header = [sentieon_D5.wgs_metrics_algo_header, sentieon_D6.wgs_metrics_algo_header, sentieon_F7.wgs_metrics_algo_header, sentieon_M8.wgs_metrics_algo_header]
  610. Array[File] sentieon_aln_metrics_header = [sentieon_D5.aln_metrics_header, sentieon_D6.aln_metrics_header, sentieon_F7.aln_metrics_header, sentieon_M8.aln_metrics_header]
  611. Array[File] sentieon_is_metrics_header = [sentieon_D5.is_metrics_header, sentieon_D6.is_metrics_header, sentieon_F7.is_metrics_header, sentieon_M8.is_metrics_header]
  612. Array[File] sentieon_quality_yield_data = [sentieon_D5.quality_yield_data, sentieon_D6.quality_yield_data, sentieon_F7.quality_yield_data, sentieon_M8.quality_yield_data]
  613. Array[File] sentieon_wgs_metrics_algo_data = [sentieon_D5.wgs_metrics_algo_data, sentieon_D6.wgs_metrics_algo_data, sentieon_F7.wgs_metrics_algo_data, sentieon_M8.wgs_metrics_algo_data]
  614. Array[File] sentieon_aln_metrics_data = [sentieon_D5.aln_metrics_data, sentieon_D6.aln_metrics_data, sentieon_F7.aln_metrics_data, sentieon_M8.aln_metrics_data]
  615. Array[File] sentieon_is_metrics_data = [sentieon_D5.is_metrics_data, sentieon_D6.is_metrics_data, sentieon_F7.is_metrics_data, sentieon_M8.is_metrics_data]
  616. call merge_sentieon_metrics.merge_sentieon_metrics as merge_sentieon_metrics {
  617. input:
  618. quality_yield_header=sentieon_quality_yield_header,
  619. wgs_metrics_algo_header=sentieon_wgs_metrics_algo_header,
  620. aln_metrics_header=sentieon_aln_metrics_header,
  621. is_metrics_header=sentieon_is_metrics_header,
  622. quality_yield_data=sentieon_quality_yield_data,
  623. wgs_metrics_algo_data=sentieon_wgs_metrics_algo_data,
  624. aln_metrics_data=sentieon_aln_metrics_data,
  625. is_metrics_data=sentieon_is_metrics_data,
  626. project=project,
  627. docker=MULTIQCdocker,
  628. cluster_config=SMALLcluster_config,
  629. disk_size=disk_size
  630. }
  631. call extract_tables.extract_tables as extract_tables {
  632. input:
  633. quality_yield_summary=merge_sentieon_metrics.quality_yield_summary,
  634. wgs_metrics_summary=merge_sentieon_metrics.wgs_metrics_summary,
  635. aln_metrics_summary=merge_sentieon_metrics.aln_metrics_summary,
  636. is_metrics_summary=merge_sentieon_metrics.is_metrics_summary,
  637. fastqc=multiqc_big.fastqc,
  638. fastqscreen=multiqc_big.fastqscreen,
  639. hap=multiqc_big.hap,
  640. project=project,
  641. docker=DIYdocker,
  642. cluster_config=SMALLcluster_config,
  643. disk_size=disk_size
  644. }
  645. call merge_family.merge_family as merge_family {
  646. input:
  647. D5_vcf=benchmark_D5.rtg_vcf,
  648. D6_vcf=benchmark_D6.rtg_vcf,
  649. F7_vcf=benchmark_F7.rtg_vcf,
  650. M8_vcf=benchmark_M8.rtg_vcf,
  651. D5_vcf_tbi=benchmark_D5.rtg_vcf_index,
  652. D6_vcf_tbi=benchmark_D6.rtg_vcf_index,
  653. F7_vcf_tbi=benchmark_F7.rtg_vcf_index,
  654. M8_vcf_tbi=benchmark_M8.rtg_vcf_index,
  655. project=project,
  656. docker=BENCHMARKdocker,
  657. cluster_config=SMALLcluster_config,
  658. disk_size=disk_size,
  659. }
  660. call mendelian.mendelian as mendelian {
  661. input:
  662. family_vcf=merge_family.family_vcf,
  663. ref_dir=ref_dir,
  664. fasta=fasta,
  665. docker=MENDELIANdocker,
  666. cluster_config=BIGcluster_config,
  667. disk_size=disk_size
  668. }
  669. call merge_mendelian.merge_mendelian as merge_mendelian {
  670. input:
  671. D5_trio_vcf=mendelian.D5_trio_vcf,
  672. D6_trio_vcf=mendelian.D6_trio_vcf,
  673. family_vcf=merge_family.family_vcf,
  674. docker=DIYdocker,
  675. cluster_config=SMALLcluster_config,
  676. disk_size=disk_size
  677. }
  678. }
  679. if (vcf_D5!= "") {
  680. call filter_vcf.filter_vcf as filter_vcf_D5_vcf {
  681. input:
  682. vcf=vcf_D5,
  683. docker=BEDTOOLSdocker,
  684. cluster_config=SMALLcluster_config,
  685. disk_size=disk_size
  686. }
  687. call benchmark.benchmark as benchmark_D5_vcf {
  688. input:
  689. filtered_vcf=filter_vcf_D5_vcf.filtered_vcf,
  690. benchmarking_dir=benchmarking_dir,
  691. ref_dir=ref_dir,
  692. fasta=fasta,
  693. docker=BENCHMARKdocker,
  694. cluster_config=BIGcluster_config,
  695. disk_size=disk_size
  696. }
  697. call filter_vcf.filter_vcf as filter_vcf_D6_vcf {
  698. input:
  699. vcf=vcf_D6,
  700. docker=BEDTOOLSdocker,
  701. cluster_config=SMALLcluster_config,
  702. disk_size=disk_size
  703. }
  704. call benchmark.benchmark as benchmark_D6_vcf {
  705. input:
  706. filtered_vcf=filter_vcf_D6_vcf.filtered_vcf,
  707. benchmarking_dir=benchmarking_dir,
  708. ref_dir=ref_dir,
  709. fasta=fasta,
  710. docker=BENCHMARKdocker,
  711. cluster_config=BIGcluster_config,
  712. disk_size=disk_size
  713. }
  714. call filter_vcf.filter_vcf as filter_vcf_F7_vcf {
  715. input:
  716. vcf=vcf_F7,
  717. docker=BEDTOOLSdocker,
  718. cluster_config=SMALLcluster_config,
  719. disk_size=disk_size
  720. }
  721. call benchmark.benchmark as benchmark_F7_vcf {
  722. input:
  723. filtered_vcf=filter_vcf_F7_vcf.filtered_vcf,
  724. benchmarking_dir=benchmarking_dir,
  725. ref_dir=ref_dir,
  726. fasta=fasta,
  727. docker=BENCHMARKdocker,
  728. cluster_config=BIGcluster_config,
  729. disk_size=disk_size
  730. }
  731. call filter_vcf.filter_vcf as filter_vcf_M8_vcf {
  732. input:
  733. vcf=vcf_M8,
  734. docker=BEDTOOLSdocker,
  735. cluster_config=SMALLcluster_config,
  736. disk_size=disk_size
  737. }
  738. call benchmark.benchmark as benchmark_M8_vcf {
  739. input:
  740. filtered_vcf=filter_vcf_M8_vcf.filtered_vcf,
  741. benchmarking_dir=benchmarking_dir,
  742. ref_dir=ref_dir,
  743. fasta=fasta,
  744. docker=BENCHMARKdocker,
  745. cluster_config=BIGcluster_config,
  746. disk_size=disk_size
  747. }
  748. Array[File] benchmark_summary_hap = [benchmark_D5_vcf.summary, benchmark_D6_vcf.summary, benchmark_F7_vcf.summary, benchmark_M8_vcf.summary]
  749. call multiqc_hap.multiqc_hap as multiqc_hap {
  750. input:
  751. summary=benchmark_summary_hap,
  752. docker=MULTIQCdocker,
  753. cluster_config=SMALLcluster_config,
  754. disk_size=disk_size
  755. }
  756. call extract_tables_vcf.extract_tables_vcf as extract_tables_vcf {
  757. input:
  758. hap=multiqc_hap.hap,
  759. project=project,
  760. docker=DIYdocker,
  761. cluster_config=SMALLcluster_config,
  762. disk_size=disk_size
  763. }
  764. call merge_family.merge_family as merge_family_vcf {
  765. input:
  766. D5_vcf=benchmark_D5_vcf.rtg_vcf,
  767. D6_vcf=benchmark_D6_vcf.rtg_vcf,
  768. F7_vcf=benchmark_F7_vcf.rtg_vcf,
  769. M8_vcf=benchmark_M8_vcf.rtg_vcf,
  770. D5_vcf_tbi=benchmark_D5_vcf.rtg_vcf_index,
  771. D6_vcf_tbi=benchmark_D6_vcf.rtg_vcf_index,
  772. F7_vcf_tbi=benchmark_F7_vcf.rtg_vcf_index,
  773. M8_vcf_tbi=benchmark_M8_vcf.rtg_vcf_index,
  774. project=project,
  775. docker=BENCHMARKdocker,
  776. cluster_config=SMALLcluster_config,
  777. disk_size=disk_size,
  778. }
  779. call mendelian.mendelian as mendelian_vcf {
  780. input:
  781. family_vcf=merge_family_vcf.family_vcf,
  782. ref_dir=ref_dir,
  783. fasta=fasta,
  784. docker=MENDELIANdocker,
  785. cluster_config=BIGcluster_config,
  786. disk_size=disk_size
  787. }
  788. call merge_mendelian.merge_mendelian as merge_mendelian_vcf {
  789. input:
  790. D5_trio_vcf=mendelian_vcf.D5_trio_vcf,
  791. D6_trio_vcf=mendelian_vcf.D6_trio_vcf,
  792. family_vcf=merge_family_vcf.family_vcf,
  793. docker=DIYdocker,
  794. cluster_config=SMALLcluster_config,
  795. disk_size=disk_size
  796. }
  797. }
  798. }