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.

903 line
24KB

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