Du kannst nicht mehr als 25 Themen auswählen Themen müssen entweder mit einem Buchstaben oder einer Ziffer beginnen. Sie können Bindestriche („-“) enthalten und bis zu 35 Zeichen lang sein.

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