...

Package pims

import "ssa/pims_analyzer/pkg/pims"
Overview
Index

Overview ▾

type PimsInfo

Stores PIMS info requested by the DAs for PIMS notification emails

type PimsInfo struct {
    // the calibration requested
    Calibration string `json:"calibration"`
    // The number of splits in the job
    NumSplits int `json:"num_splits"`
    // Path to restored MS
    RestoredMSPath string `json:"restore_path"`
    // Path to CASA used
    CasaVersion string `json:"casa_path"`
    // lustre processing area
    WorkingDir string `json:"lustre_dir"`
    // output cache directory
    CacheDir string `json:"cache_dir"`
    // number of SE and CC products per tile
    NumProducts []TileProductCounts `json:"num_products"`
    // used to determine workflow status header message
    StatusMsg string `json:"status"`
    // contains the failed splits in `tile.phasecenter` format
    FailedSplits []string `json:"failed_splits"`
    // Num failed splits (needs to be in JSON to get passed to email template)
    NumFailedSplits int `json:"num_failed_splits"`
}

func GetPimsInfo

func GetPimsInfo(workflowId int, capoPath string, capoProfile string) PimsInfo

GetPimsInfo Populates a PimsInfo struct with data from a given workflow identified by the workflow ID

@param workflowId the ID of the PIMS workflow @param capoPath the path to the capo property file @param capProfile the CAPO profile used during the workflow execution

type TileProductCounts

Stores the number of SEs and CCs in the database for a tile

type TileProductCounts struct {
    // Name of the Tile
    Tile string `json:"tile_name"`
    // Number of coarse cubes associated
    NumCoarseCubes int `json:"num_coarse_cube"`
    // Number of continuum images associated
    NumContinuum int `json:"num_continuum"`
}