Source code for liger_iris_pipeline.pipeline.rop

#!/usr/bin/env python
import logging
from collections import defaultdict
import os.path as op

from jwst import datamodels
from jwst.associations.load_as_asn import LoadAsLevel2Asn
from jwst.stpipe import Pipeline
from liger_iris_pipeline import datamodels

# step imports
from ..readout import readoutsamp_step
from ..readout import nonlincorr_step
__all__ = ['rop']

# Define logging
log = logging.getLogger()
log.setLevel(logging.DEBUG)


[docs] class ROPPipeline(Pipeline): """ Detector1Pipeline for IRIS """ spec = """ save_calibrated_ramp = boolean(default=False) """ # Define aliases to steps step_defs = { "nonlincorr": nonlincorr_step.NonlincorrStep, "readoutsamp": readoutsamp_step.ReadoutsampStep, } # start the actual processing
[docs] def process(self, input): log.info('Starting ROP Pipeline ...') # open the input as a RampModel input = datamodels.RampModel(input) input = self.nonlincorr(input) input = self.readoutsamp(input) return input
[docs] def setup_output(self, input): # Determine the proper file name suffix to use later if input.meta.cal_step.ramp_fit == 'COMPLETE': self.suffix = 'rate' else: self.suffix = 'ramp'