diff --git a/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py b/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py index c9caac7fcfbe3f55aadc2e1ddc2bf96cf677c8ec..45bde4289eb30f986b40418d753c71cdf728ed14 100644 --- a/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py +++ b/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py @@ -48,7 +48,13 @@ NGASHOSTSTR=$(./pycapo -q archive-ingestion.NGASHosts) NGASHOSTARR=(`/bin/echo ${NGASHOSTSTR}`) # Put the space-delimited host list into an array NGASHOSTLEN=${#NGASHOSTARR[@]} -cd $1 +# Copy from the difx area to the Workspaces staging area +WSSTAGINGDIR=$(./pycapo -q edu.nrao.workspaces.IngestionSettings.vlbiStagingDirectory) +/bin/cp -r $1 $WSSTAGINGDIR + +OBSDIR=$(/bin/basename $1) +/bin/chmod -R 750 $WSSTAGINGDIR/$OBSDIR # Make sure NGAS has permissions to ingest the files +cd $WSSTAGINGDIR/$OBSDIR for FILE in *; do # Pick random NGAS host to distribute the ingestion load