#!/bin/bash
# Usage: run_sac.sh numcores hostsFilename workDir map resType patType patterns
cores=$1
hosts=$2
wd=$3
mapper=$4
shift
shift
shift
shift
rm -f allout

# Get quoting right...
worker () {
  f=$1
  shift
  mapper=$1
  shift
  shift # we don't need/want the resType either
  hostname 1>&2
  export PYTHONIOENCODING=utf-8
  curl -s -N https://commoncrawl.s3.amazonaws.com/$f | \
   unpigz -dp 1 -c | tee >(wc -l 1>&2) | ./$mapper "$@" 2>&1
}

export -f worker

parallel -v \
    --sshloginfile $hosts \
    --retries 3 \
    --transferfile $(which $mapper|sed 's/\(^.*\/\)/\1.\//') \
    --will-cite \
    --jobs $cores \
    --workdir $wd \
    -a input_paths \
    --env worker \
    worker '{}' "$mapper" "$@" | tee -a allout | grep -v 'Authorized uses only' | \
    sac_reducer.py "$@"