Related Github Repos and tickets
Tickets:
Job Runtime
Depends on how many SLCs are being procssed
1+ hours for 8 SLCs
Objective
Creating a stack of SLCs
Only within the same track (over a time period)
Prerequisite to STAMPS processing
How to set up the inputs
Facets to get SLC inputs
region (ex. Hawaii) (optional)
track_number
ortrackNumber
(depends)datatype:
SLC
If SLCs track number do not match, then it would throw this error in the job:
raise Exception('Could not determine a suitable burst offset')
There must only be one track in your SLC inputs
correct facet SLC inputs incorrect facet SLC inputs
Job Inputs:
Bbox (*required)
min_lat
max_lat
min_lon
max_lon
CI Integration (Jenkins)
Link: http://b-ci.grfn.hysds.io:8080/job/ops-bcluster_container-builder_aria-jpl_topsstack_master/
WARNING: If rebuilding on the same branch (master), make sure to remove docker image so that it reloads when restarting the job:
docker rmi <topsStack docker image id>
HySDS-io and Jobspec-io
hysds-io.json.topsstack
{ "label": "topsStack Processor", "submission_type": "individual", "allowed_accounts": [ "ops" ], "action-type": "both", "params": [ { "name": "min_lat", "from": "submitter", "type": "number", "optional": false }, { "name": "max_lat", "from": "submitter", "type": "number", "optional": false }, { "name": "min_lon", "from": "submitter", "type": "number", "optional": false }, { "name": "max_lon", "from": "submitter", "type": "number", "optional": false }, { "name":"localize_products", "from":"dataset_jpath:", "type":"text", "lambda" : "lambda met: get_partial_products(met['_id'],get_best_url(met['_source']['urls']),[met['_id']+'.zip'])" } ] }
job-spec.json.topsstack
{ "recommended_queues": ["jjacob_stack"], "command": "/home/ops/verdi/ops/topsstack/run_stack.sh", "imported_worker_files": { "/home/ops/.netrc": "/home/ops/.netrc", "/home/ops/.aws": "/home/ops/.aws" }, "soft_time_limit": 10800, "time_limit": 18000, "disk_usage": "100GB", "params": [ { "name": "min_lat", "destination": "context" }, { "name": "max_lat", "destination": "context" }, { "name": "min_lon", "destination": "context" }, { "name": "max_lon", "destination": "context" }, { "name":"localize_products", "destination": "localize" } ] }
Job Outputs
Main file that gets executed is run_stack.sh
Copies all SLCs
.zip
files tozip/
sub-directoryruns
get_bbox.py
and exports 8 coordinates as inputs for the science coderead MINLAT MAXLAT MINLON MAXLON MINLAT_LO MAXLAT_HI MINLON_LO MAXLON_HI <<< $TOKENS
Runs 10 steps to complete the stack processor
run.py -i ./run_files/run_1_unpack_slc_topo_master -p 8
run.py -i ./run_files/run_2_average_baseline -p 8
run.py -i ./run_files/run_3_extract_burst_overlaps -p 8
run.py -i ./run_files/run_4_overlap_geo2rdr_resample -p 8
run.py -i ./run_files/run_5_pairs_misreg -p 8
run.py -i ./run_files/run_6_timeseries_misreg -p 8
run.py -i ./run_files/run_7_geo2rdr_resample -p 8
run.py -i ./run_files/run_8_extract_stack_valid_region -p 8
run.py -i ./run_files/run_9_merge -p 8
run.py -i ./run_files/run_10_grid_baseline -p 8
Output directory structure
Output structure of merged/
merged/ baselines/ 20190506/ 20190518/ 20190530/ 20190530 20190530.full.vrt 20190530.vrt 20190530.xml geom_master/ *.rdr.aux.xml *.rdr.full *.rdr.full.aux.xml *.rdr.full.vrt *.rdr.full.xml SLC/ 20190506/ 20190518/ 20190530/ 20190530.slc.full 20190530.slc.full.aux.xml 20190530.slc.full.vrt 20190530.slc.full.xml 20190530.slc.hdr
STILL TODO:
Publish the contents from
merged/
into a datasets directoryCreate dataset file name template
Add regex and entry to
etc/_datasets.json
0 Comments