Index

A

addlock() (in module ScratchDisk) AWSCluster module

AWSCluster (class in AWSCluster)

B

baseline_from_Job() (in module job_tasks) BCKTFLDR (FVCOMForecast.FVCOMForecast attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute) bounding_tile() (tile.TileBase method) bounds() (tile.Tile3857 method) (tile.Tile4326 method) (tile.TileBase method)

BUCKET (FVCOMForecast.FVCOMForecast attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute) buffer() (tile.TileBase method)

C

CDATE (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute) Cluster module Cluster (class in Cluster) cluster() (ClusterFactory.ClusterFactory method) cluster_init() (in module cluster_tasks) cluster_start() (in module cluster_tasks) cluster_tasks module cluster_terminate() (in module cluster_tasks)

ClusterFactory module ClusterFactory (class in ClusterFactory) COMROT (FVCOMForecast.FVCOMForecast attribute) (ROMSForecast.ROMSForecast attribute) configfile (Cluster.Cluster attribute) (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute) create() (FSxScratchDisk.FSxScratchDisk method) (NFSScratchDisk.NFSScratchDisk method) (ScratchDisk.ScratchDisk method) create_scratch() (in module tasks)

D

dask_client_close() (in module cluster_tasks) daskmake_diff_plots() (in module job_tasks) daskmake_mpegs() (in module job_tasks) daskmake_plots() (in module job_tasks) daskscheduler (AWSCluster.AWSCluster attribute) (Cluster.Cluster attribute) (LocalCluster.LocalCluster attribute) daskworker (AWSCluster.AWSCluster attribute) (Cluster.Cluster attribute) (LocalCluster.LocalCluster attribute)

DATE_REF (FVCOMForecast.FVCOMForecast attribute) debug_model() (in module flows) delete() (FSxScratchDisk.FSxScratchDisk method) (NFSScratchDisk.NFSScratchDisk method) (ScratchDisk.ScratchDisk method) delete_scratch() (in module tasks) diff_plot_flow() (in module flows) downloadFile() (S3Storage.S3Storage method) (StorageService.StorageService method)

E

EXEC (ROMSForecast.ROMSForecast attribute)

extract_ncdata() (in module plot_fvcom) (in module plot_roms)

F

fcst_flow() (in module flows) (in module run_adnoc) fetchpy_and_run() (in module tasks) file_exists() (S3Storage.S3Storage method) (StorageService.StorageService method) flows module forecast_run() (in module tasks)

FSPEC (Job.Job attribute) (Plotting.Plotting attribute) FSxScratchDisk module FSxScratchDisk (class in FSxScratchDisk) FVCOMForecast module FVCOMForecast (class in FVCOMForecast)

G

get_baseline() (in module job_tasks) get_baseline_lo() (in module romsUtil) get_forcing() (in module job_tasks) get_ICs_lo() (in module romsUtil) get_ICs_roms() (in module romsUtil) get_lockcount() (in module ScratchDisk) get_projection() (in module plot_fvcom) (in module plot_roms) get_vmin_vmax() (in module plot_fvcom) (in module plot_roms) getCoresPN() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method)

getHosts() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method) getHostsCSV() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method) getPPN() (in module nodeInfo) getState() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method) getTiling() (in module romsUtil)

H

handler() (in module flows) (in module nosofs_qops) (in module run_adnoc) (in module workflow_main)

haslocks() (in module ScratchDisk) HH (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute)

I

image_id (AWSCluster.AWSCluster attribute) INDIR (Job.Job attribute) (Plotting.Plotting attribute)

ININAME (ROMSForecast.ROMSForecast attribute) inject_notebook() (in module flows) INPUTFILE (FVCOMForecast.FVCOMForecast attribute) INTMPL (FVCOMForecast.FVCOMForecast attribute)

J

Job module Job (class in Job) job() (JobFactory.JobFactory method) job_init() (in module tasks) job_tasks module

JobFactory module JobFactory (class in JobFactory) jobtype (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute)

K

key_name (AWSCluster.AWSCluster attribute)

L

lo_date() (in module romsUtil) LocalCluster module

LocalCluster (class in LocalCluster) LOCALNEST (FVCOMForecast.FVCOMForecast attribute)

M

main() (in module nosofs_qops) (in module run_adnoc) (in module workflow_main) make_fcstin() (FVCOMForecast.FVCOMForecast method) make_oceanin() (ROMSForecast.ROMSForecast method) make_png() (in module plot_fvcom) (in module plot_roms) makeOceanin() (in module romsUtil) module AWSCluster Cluster cluster_tasks ClusterFactory flows FSxScratchDisk FVCOMForecast Job job_tasks JobFactory LocalCluster NFSScratchDisk nodeInfo nosofs_qops plot_fvcom plot_roms Plotting ROMSForecast romsUtil run_adnoc S3Storage ScratchDisk shared StorageService tasks tile workflow_main

mount_scratch() (in module tasks)

N

ncfiles_from_Job() (in module job_tasks) ncfiles_glob() (in module job_tasks) ndate() (in module romsUtil) ndate_hrs() (in module romsUtil) ndays() (in module romsUtil) NFSScratchDisk module NFSScratchDisk (class in NFSScratchDisk) nodeCount (AWSCluster.AWSCluster attribute) (LocalCluster.LocalCluster attribute) nodeInfo module

nodeType (AWSCluster.AWSCluster attribute) (LocalCluster.LocalCluster attribute) nosofs_qops module notebook_flow() (in module flows) notebook_test() (in module flows) NPROCS (AWSCluster.AWSCluster attribute) (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute) NTIMES (ROMSForecast.ROMSForecast attribute) nudge() (tile.TileBase method)

O

OCEANIN (ROMSForecast.ROMSForecast attribute) OCNINTMPL (ROMSForecast.ROMSForecast attribute) OFS (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute)

OUTDIR (FVCOMForecast.FVCOMForecast attribute) (Job.Job attribute) (Plotting.Plotting attribute) (ROMSForecast.ROMSForecast attribute)

P

parent_tile() (tile.TileBase method) parseConfig() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (FVCOMForecast.FVCOMForecast method) (Job.Job method) (LocalCluster.LocalCluster method) (Plotting.Plotting method) (ROMSForecast.ROMSForecast method) placement_group (AWSCluster.AWSCluster attribute) platform (AWSCluster.AWSCluster attribute) (Cluster.Cluster attribute) (LocalCluster.LocalCluster attribute) plot() (in module plot_fvcom) (in module plot_roms) plot_data() (in module plot_fvcom) (in module plot_roms)

plot_diff() (in module plot_fvcom) (in module plot_roms) plot_flow() (in module flows) plot_fvcom module plot_roms module Plotting module Plotting (class in Plotting) png_ffmpeg() (in module shared) PPN (AWSCluster.AWSCluster attribute) (LocalCluster.LocalCluster attribute) PTMP (FVCOMForecast.FVCOMForecast attribute) (ROMSForecast.ROMSForecast attribute) ptmp2com() (in module job_tasks) push_pyEnv() (in module cluster_tasks)

Q

quadkey() (tile.TileBase method)

quadkey_to_tile() (tile.TileBase method)

R

readConfig() (AWSCluster.AWSCluster method) (Cluster.Cluster method) readconfig() (ClusterFactory.ClusterFactory method) readConfig() (in module romsUtil) (in module ScratchDisk) (Job.Job method) readconfig() (JobFactory.JobFactory method) readConfig() (LocalCluster.LocalCluster method) remote_mount() (FSxScratchDisk.FSxScratchDisk method) (NFSScratchDisk.NFSScratchDisk method) (ScratchDisk.ScratchDisk method)

removelock() (in module ScratchDisk) ROMSForecast module ROMSForecast (class in ROMSForecast) romsUtil module run_adnoc module run_pynotebook() (in module tasks)

S

S3Storage module S3Storage (class in S3Storage) save_to_cloud() (in module tasks) ScratchDisk module ScratchDisk (class in ScratchDisk) scrub_liveocean() (in module romsUtil) sedoceanin() (in module romsUtil) set_diff_filename() (in module shared) set_filename() (in module shared) setDaskScheduler() (Cluster.Cluster method) setDaskWorker() (Cluster.Cluster method) setState() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method)

settings (Job.Job attribute) sg_ids (AWSCluster.AWSCluster attribute) shared module start() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method) start_dask() (in module cluster_tasks) storage_init() (in module tasks) StorageService module StorageService (class in StorageService) subnet_id (AWSCluster.AWSCluster attribute)

T

tags (AWSCluster.AWSCluster attribute) tasks module TEMPLPATH (FVCOMForecast.FVCOMForecast attribute) (ROMSForecast.ROMSForecast attribute) terminate() (AWSCluster.AWSCluster method) (Cluster.Cluster method) (LocalCluster.LocalCluster method) terminateDaskScheduler() (Cluster.Cluster method) terminateDaskWorker() (Cluster.Cluster method) test_flow() (in module flows)

test_nbflow() (in module flows) tile module tile() (tile.Tile3857 method) (tile.Tile4326 method) (tile.TileBase method) Tile3857 (class in tile) Tile4326 (class in tile) tile_ij() (tile.TileBase method) TileBase (class in tile) TIME_REF (ROMSForecast.ROMSForecast attribute)

U

uploadFile() (S3Storage.S3Storage method) (StorageService.StorageService method)

V

VARS (Job.Job attribute) (Plotting.Plotting attribute)

VERIFDIR (Plotting.Plotting attribute) viewport() (tile.TileBase method)

W

workflow_main module

Z

zoomout() (tile.TileBase method)