1318c99c7958fcfacf703bf6047b7ae25bd6efc9 angie Sun Mar 20 10:25:12 2022 -0700 Make hgwdev URL to share daily directories with processed COG-UK files. diff --git src/hg/utils/otto/sarscov2phylo/getCogUk.sh src/hg/utils/otto/sarscov2phylo/getCogUk.sh index 1d418c2..6cac2c6 100755 --- src/hg/utils/otto/sarscov2phylo/getCogUk.sh +++ src/hg/utils/otto/sarscov2phylo/getCogUk.sh @@ -1,79 +1,82 @@ #!/bin/bash set -beEux -o pipefail # Download latest COG-UK fasta and metadata; update $ottoDir/cogUk.latest link. scriptDir=$(dirname "${BASH_SOURCE[0]}") source $scriptDir/util.sh today=$(date +%F) ottoDir=/hive/data/outside/otto/sarscov2phylo cogUrlBase=https://cog-uk.s3.climb.ac.uk/phylogenetics/latest mkdir -p $ottoDir/cogUk.$today cd $ottoDir/cogUk.$today # Sometimes the curl fails with a DNS error, regardless of whether my previous cron job with # curl -I succeeded. Do multiple retries for the first URL; once it's working, it should # continue to work for the other URLs (she said hopefully). # On some days, the fetch started but failed partway through, even after 5 tries, so # keep the partial result around and try again with '-C -'. attempt=0 maxAttempts=5 retryDelay=60 while [[ $((++attempt)) -le $maxAttempts ]]; do echo "curl attempt $attempt" if curl -S -s -C - -O $cogUrlBase/cog_all.fasta.gz; then break else echo "FAILED; will try again after $retryDelay seconds" sleep $retryDelay fi done if [[ $attempt -gt $maxAttempts ]]; then echo "curl failed $maxAttempts times; quitting." exit 1 fi curl -S -s -C - -O $cogUrlBase/cog_metadata.csv.gz gunzip cog_metadata.csv.gz curl -S -s -C - -O $cogUrlBase/cog_global_tree.newick zcat cog_all.fasta.gz | xz -T 20 > cog_all.fasta.xz rm cog_all.fasta.gz tail -n +2 cog_metadata.csv \ | awk -F, '{print $1 "\t" $5;}' | sort > cogUkToDate # Reuse nextclade assignments for older sequences; compute nextclade assignments for new seqs. zcat $ottoDir/cogUk.latest/nextclade.full.tsv.gz > nextclade.full.tsv cp $ottoDir/cogUk.latest/nextalign.fa.xz . comm -13 <(cut -f 1 nextclade.full.tsv | sort) <(fastaNames cog_all.fasta.xz | sort) \ > seqsForNextclade if [ -s seqsForNextclade ]; then splitDir=splitForNextclade rm -rf $splitDir mkdir $splitDir faSomeRecords <(xzcat cog_all.fasta.xz) seqsForNextclade stdout \ | faSplit about stdin 300000000 $splitDir/chunk nDataDir=~angie/github/nextclade/data/sars-cov-2 outDir=$(mktemp -d) outTsv=$(mktemp) for chunkFa in $splitDir/chunk*.fa; do nextclade -j 30 -i $chunkFa \ --input-dataset $nDataDir \ --output-dir $outDir \ --output-basename out \ --output-tsv $outTsv >& nextclade.log tail -n+2 $outTsv | sed -re 's/"//g;' >> nextclade.full.tsv xz -T 20 < $outDir/out.aligned.fasta >> nextalign.fa.xz rm -f $outTsv $outDir/* done rm -rf $outDir rm -rf $splitDir fi pigz -f -p 8 nextclade.full.tsv rm -f $ottoDir/cogUk.latest ln -s cogUk.$today $ottoDir/cogUk.latest + +rm -f ~angie/public_html/sarscov2phylo/cogUk.$today +ln -s $ottoDir/cogUk.$today ~angie/public_html/sarscov2phylo/cogUk.$today