Yano

yano

Source code in mfx/yano.py

class yano:
    def __init__(self):
        from mfx.devices import LaserShutter
        from pcdsdevices.evr import Trigger
        self.delay = None

        # Declare shutter objects
        self.opo_shutter = LaserShutter('MFX:USR:ao1:6', name='opo_shutter')
        self.evo_shutter1 = LaserShutter('MFX:USR:ao1:7', name='evo_shutter1')
        self.evo_shutter2 = LaserShutter('MFX:USR:ao1:2', name='evo_shutter2')
        self.evo_shutter3 = LaserShutter('MFX:USR:ao1:3', name='evo_shutter3')

        # Trigger objects
        self.opo = Trigger('MFX:LAS:EVR:01:TRIG6', name='opo_trigger')
        self.evo = Trigger('MFX:LAS:EVR:01:TRIG5', name='evo_trigger')

        # Laser parameter
        self.opo_time_zero = 671765

        # Event code switch logic for longer delay
        self.opo_ec_short = 212
        self.opo_ec_long = 211
        self.opo_ec_longer = 210
        self.PP = 197
        self.DAQ = 198
        self.WATER = 211
        self.SAMPLE = 212
        self.rep_rate = 20


    @property
    def shutter_status(self):
        """Show current shutter status"""
        status = []
        for shutter in (self.evo_shutter1, self.evo_shutter2,
                        self.evo_shutter3, self.opo_shutter):
            status.append(shutter.state.get())
        return status


    def configure_shutters(self, fiber1=False, fiber2=False, fiber3=False, free_space=None):
        """
        Configure all four laser shutters

        True means that the fiber will be used and the shutter is removed.
        False means that the fiber will be blocked and the shutter is inserted 
           - default for evo laser fiber1, fiber2, fiber3
        None means that the shutter will not be changed
           - default for opo laser

        Parameters
        ----------
        fiber1: bool
            Controls ``evo_shutter1``

        fiber2: bool
            Controls ``evo_shutter2``

        fiber3: bool
            Controls ``evo_shutter3``

        free_space: bool
            Controls ``opo_shutter``
        """
        from time import sleep
        for state, shutter in zip((fiber1, fiber2, fiber3, free_space),
                                  (self.evo_shutter1, self.evo_shutter2,
                                   self.evo_shutter3, self.opo_shutter)):
            if state is not None:
                if state == True or state == 'OUT' or state == 2:
                    shutter('OUT')
                else:
                    shutter('IN')
        #logger.info("Shutters set to fiber1=%s, fiber2=%s, fiber3=%s, free_space=%s", fiber1, fiber2, fiber3, free_space)
        sleep(1)
        return


    def fiber_0(self):
        return self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=None)


    def fiber_1(self):
        return self.configure_shutters(fiber1=False, fiber2=False, fiber3=True, free_space=None)


    def fiber_2(self):
        return self.configure_shutters(fiber1=False, fiber2=True, fiber3=True, free_space=None)


    def fiber_3(self):
        return self.configure_shutters(fiber1=True, fiber2=True, fiber3=True, free_space=None)


    def _delaystr(self, delay):
        """
        OPO delay string
        """
        if self.opo_shutter.state.value == 'IN':
            return 'No OPO Laser'
        elif delay >= 1e6:
            return 'Laser delay is set to {:10.6f} ms'.format(delay/1.e6)
        elif delay >= 1e3:
            return 'Laser delay is set to {:7.3f} us'.format(delay/1.e3)
        elif delay >= 0:
            return 'Laser delay is set to {:4.0f} ns'.format(delay)
        else:
            return 'Laser delay is set to {:8.0f} ns (AFTER X-ray pulse)'.format(delay)


    def _wrap_delay(self, delay, base_rate=120):
        """
        given a delay in units of nanoseconds, wrap the delay so that
        it is strictly less than the period of the base_rate
        """
        if delay*1E-9 > 1/base_rate:
            adjusted_delay = delay - (1/base_rate)*1E9
        else:
            adjusted_delay = delay
        return adjusted_delay 


    def set_delay(self, delay):
        """
        Set the delay

        Parameters
        ----------
        delay: float
            Requested laser delay in nanoseconds.
        """
        import logging
        logger = logging.getLogger(__name__)
        # Determine event code of inhibit pulse
        logger.info("Setting delay %s ns (%s us)", delay, delay/1000.)
        self.delay = delay
        opo_delay = self.opo_time_zero - delay
        opo_ec = self.opo_ec_short
        if delay > self.opo_time_zero + 1e9/120:
            opo_delay += 2e9/120
            opo_ec = self.opo_ec_longer
            logger.info('Laser is 2 buckets before the beam')
        elif delay > self.opo_time_zero:
            opo_delay += 1e9/120
            opo_ec = self.opo_ec_long
            logger.info('Laser is 1 bucket before the beam')
        else:
            logger.info('Laser is in the same bucket as the beam')      


        self.opo.ns_delay.put(opo_delay)
        logger.info("Setting OPO delay %s ns", opo_delay)
        self.opo.eventcode.put(opo_ec)
        logger.info("Setting OPO ec %s", opo_ec)
        logger.info(self._delaystr(delay))
        return


    def get_delay(self):
        """
        Reads the current delay in ns

        Parameters
        ----------
        delay: float
            Requested laser delay in nanoseconds.
        """
        import logging
        logger = logging.getLogger(__name__)
        if self.opo.eventcode.get() == self.opo_ec_long:
            opo_delay = self.opo.ns_delay.get() - 1e9/120
        else:
            opo_delay = self.opo.ns_delay.get()
        delay = self.opo_time_zero - opo_delay 
        logger.info(self._delaystr(delay))
        return delay


    def post(self, sample='?', run_number=None, post=False, inspire=False, add_note=''):
        """
        Posts a message to the elog

        Parameters
        ----------
        sample: str, optional
            Sample Name

        run_number: int, optional
            Run Number. By default this is read off of the DAQ

        post: bool, optional
            set True to record/post message to elog

        inspire: bool, optional
            Set false by default because it makes Sandra sad. Set True to inspire

        add_note: string, optional
            adds additional note to elog message 
        """
        from mfx.db import daq, elog
        from mfx.autorun import quote
        post_template = """\
        Run Number {}: {}

        {}

        While the laser shutters are:
        EVO fiber 1 ->  {}
        EVO fiber 2 ->  {}
        EVO fiber 3 ->  {}
        OPO Shutter ->  {}
        """
        if add_note!='':
            add_note = '\n' + add_note
        if inspire:
            comment = f"Running {sample}\n{quote()['quote']}{add_note}"
        else:
            comment = f"Running {sample}{add_note}"
        delay = self.get_delay()
        if run_number is None:
            run_number = daq.run_number()
        info = [run_number, comment, self._delaystr(delay)]
        info.extend(self.shutter_status)
        post_msg = post_template.format(*info)
        print('\n' + post_msg + '\n')
        if post:
            elog.post(msg=post_msg, run=(run_number))
        return post_msg


    def begin(self, events=None, duration=300,
              record=False, use_l3t=None, controls=None,
              wait=False, end_run=False):
        """
        Start the daq and block until the daq has begun acquiring data.

        Optionally block with ``wait=True`` until the daq has finished aquiring
        data. If blocking, a ``ctrl+c`` will end the run and clean up.

        If omitted, any argument that is shared with `configure`
        will fall back to the configured value.

        Internally, this calls `kickoff` and manages its ``Status`` object.

        Parameters
        ----------
        events: ``int``, optional
            Number events to take in the daq.

        duration: ``int``, optional
            Time to run the daq in seconds, if ``events`` was not provided.

        record: ``bool``, optional
            If ``True``, we'll configure the daq to record data before this
            run.

        use_l3t: ``bool``, optional
            If ``True``, we'll run with the level 3 trigger. This means that
            if we specified a number of events, we will wait for that many
            "good" events as determined by the daq.

        controls: ``dict{name: device}`` or ``list[device...]``, optional
            If provided, values from these will make it into the DAQ data
            stream as variables. We will check ``device.position`` and
            ``device.value`` for quantities to use and we will update these
            values each time begin is called. To provide a list, all devices
            must have a ``name`` attribute.

        wait: ``bool``, optional
            If ``True``, wait for the daq to finish aquiring data. A
            ``KeyboardInterrupt`` (``ctrl+c``) during this wait will end the
            run and clean up.

        end_run: ``bool``, optional
            If ``True``, we'll end the run after the daq has stopped.
        """
        import logging
        logger = logging.getLogger(__name__)
        from time import sleep
        from mfx.db import daq

        logger.debug(('Daq.begin(events=%s, duration=%s, record=%s, '
                      'use_l3t=%s, controls=%s, wait=%s)'),
                     events, duration, record, use_l3t, controls, wait)
        status = True
        try:
            if record is not None and record != daq.record:
                old_record = daq.record
                daq.preconfig(record=record, show_queued_cfg=False)
            begin_status = daq.kickoff(events=events, duration=duration,
                                        use_l3t=use_l3t, controls=controls)
            try:
                begin_status.wait(timeout=daq._begin_timeout)
            except (StatusTimeoutError, WaitTimeoutError):
                msg = (f'Timeout after {self._begin_timeout} seconds waiting '
                       'for daq to begin.')
                raise DaqTimeoutError(msg) from None

            # In some daq configurations the begin status returns very early,
            # so we allow the user to configure an emperically derived extra
            # sleep.
            sleep(daq.config['begin_sleep'])
            if wait:
                daq.wait()
                if end_run:
                    daq.end_run()
            if end_run and not wait:
                threading.Thread(target=daq._ender_thread, args=()).start()
            return status
        except KeyboardInterrupt:
                status = False
                return status


    def yano_run(self, sample='?', run_length=300, record=True, runs=5, inspire=False, daq_delay=5, picker=None, fiber=-1, free_space=None, laser_delay=None):
        """
        Perform a single run of the experiment

        Parameters
        ----------
        sample: str, optional
            Sample Name

        run_length: int, optional
            number of seconds for run 300 is default

        record: bool, optional
            set True to record

        runs: int, optional
            number of runs 5 is default

        inspire: bool, optional
            Set false by default because it makes Sandra sad. Set True to inspire

        daq_delay: int, optional
            delay time between runs. Default is 5 second but increase is the DAQ is being slow.

        picker: str, optional
            If 'open' it opens pp before run starts. If 'flip' it flipflops before run starts

        fiber: int, optional
            Number of laser fibers. Default is -1. See ``configure_shutters`` for more
            information

        free_space: bool, optional
            Sets the free_space laser shutter to Closed (False) or Open (True). Default is None.

        laser_delay: float
            Requested laser delay in nanoseconds.
        Note
        ----
        0: (fiber1=False, fiber2=False, fiber3=False)
        1: (fiber1=False, fiber2=False, fiber3=True)
        2: (fiber1=False, fiber2=True, fiber3=True)
        3: (fiber1=True, fiber2=True, fiber3=True)

        For alternative laser configurations either use ``configure_shutters`` to set parameters
        """
        import logging
        logger = logging.getLogger(__name__)
        from time import sleep
        from mfx.db import daq, pp
        from mfx.autorun import quote

        # Configure the shutters
        if fiber == 0:
            self.fiber_0()
        elif fiber == 1:
            self.fiber_1()
        elif fiber == 2:
            self.fiber_2()
        elif fiber == 3:
            self.fiber_3()
        else:
            logger.warning("No proper fiber number set so defaulting to ``configure_shutters`` settings.")

        if free_space is not None:
            if free_space == True or str(
                free_space).lower()==str('out') or int(
                    free_space) == 2 or str(
                        free_space).lower()==str('open'):
                self.opo_shutter('OUT')
            else:
                self.opo_shutter('IN')

        if laser_delay is not None:
            self.set_delay(laser_delay)
        delay = self.get_delay()
        logger.info(self._delaystr(delay))

        if sample.lower()=='water' or sample.lower()=='h2o':
            inspire=True
        if picker=='open':
            pp.open()
        if picker=='flip':
            pp.flipflop()

        for i in range(runs):
            logger.info(f"Run Number {daq.run_number() + 1} Running {sample}......{quote()['quote']}")
            run_number = daq.run_number() + 1
            status = self.begin(duration = run_length, record = record, wait = True, end_run = True)
            if status is False:
                pp.close()
                self.post(sample, run_number, record, inspire, 'Run ended prematurely. Probably sample delivery problem')
                self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=False)
                logger.warning("[*] Stopping Run and exiting???...")
                sleep(5)
                daq.stop()
                daq.disconnect()
                logger.warning('Run ended prematurely. Probably sample delivery problem')
                break

            self.post(sample, run_number, record, inspire)
            try:
                sleep(daq_delay)
            except KeyboardInterrupt:
                pp.close()
                self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=False)
                logger.warning("[*] Stopping Run and exiting???...")
                sleep(5)
                daq.disconnect()
                status = False
                if status is False:
                    logger.warning('Run ended prematurely. Probably sample delivery problem')
                    break
        if status:
            pp.close()
            self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=False)
            daq.end_run()
            daq.disconnect()
            logger.warning('Finished with all runs thank you for choosing the MFX beamline!\n')

shutter_status property

Show current shutter status

begin(events=None, duration=300, record=False, use_l3t=None, controls=None, wait=False, end_run=False)

Start the daq and block until the daq has begun acquiring data.

Optionally block with wait=True until the daq has finished aquiring data. If blocking, a ctrl+c will end the run and clean up.

If omitted, any argument that is shared with configure will fall back to the configured value.

Internally, this calls kickoff and manages its Status object.

Parameters

events: int, optional Number events to take in the daq.

int, optional

Time to run the daq in seconds, if events was not provided.

bool, optional

If True, we'll configure the daq to record data before this run.

bool, optional

If True, we'll run with the level 3 trigger. This means that if we specified a number of events, we will wait for that many "good" events as determined by the daq.

dict{name: device} or list[device...], optional

If provided, values from these will make it into the DAQ data stream as variables. We will check device.position and device.value for quantities to use and we will update these values each time begin is called. To provide a list, all devices must have a name attribute.

bool, optional

If True, wait for the daq to finish aquiring data. A KeyboardInterrupt (ctrl+c) during this wait will end the run and clean up.

bool, optional

If True, we'll end the run after the daq has stopped.

Source code in mfx/yano.py

def begin(self, events=None, duration=300,
          record=False, use_l3t=None, controls=None,
          wait=False, end_run=False):
    """
    Start the daq and block until the daq has begun acquiring data.

    Optionally block with ``wait=True`` until the daq has finished aquiring
    data. If blocking, a ``ctrl+c`` will end the run and clean up.

    If omitted, any argument that is shared with `configure`
    will fall back to the configured value.

    Internally, this calls `kickoff` and manages its ``Status`` object.

    Parameters
    ----------
    events: ``int``, optional
        Number events to take in the daq.

    duration: ``int``, optional
        Time to run the daq in seconds, if ``events`` was not provided.

    record: ``bool``, optional
        If ``True``, we'll configure the daq to record data before this
        run.

    use_l3t: ``bool``, optional
        If ``True``, we'll run with the level 3 trigger. This means that
        if we specified a number of events, we will wait for that many
        "good" events as determined by the daq.

    controls: ``dict{name: device}`` or ``list[device...]``, optional
        If provided, values from these will make it into the DAQ data
        stream as variables. We will check ``device.position`` and
        ``device.value`` for quantities to use and we will update these
        values each time begin is called. To provide a list, all devices
        must have a ``name`` attribute.

    wait: ``bool``, optional
        If ``True``, wait for the daq to finish aquiring data. A
        ``KeyboardInterrupt`` (``ctrl+c``) during this wait will end the
        run and clean up.

    end_run: ``bool``, optional
        If ``True``, we'll end the run after the daq has stopped.
    """
    import logging
    logger = logging.getLogger(__name__)
    from time import sleep
    from mfx.db import daq

    logger.debug(('Daq.begin(events=%s, duration=%s, record=%s, '
                  'use_l3t=%s, controls=%s, wait=%s)'),
                 events, duration, record, use_l3t, controls, wait)
    status = True
    try:
        if record is not None and record != daq.record:
            old_record = daq.record
            daq.preconfig(record=record, show_queued_cfg=False)
        begin_status = daq.kickoff(events=events, duration=duration,
                                    use_l3t=use_l3t, controls=controls)
        try:
            begin_status.wait(timeout=daq._begin_timeout)
        except (StatusTimeoutError, WaitTimeoutError):
            msg = (f'Timeout after {self._begin_timeout} seconds waiting '
                   'for daq to begin.')
            raise DaqTimeoutError(msg) from None

        # In some daq configurations the begin status returns very early,
        # so we allow the user to configure an emperically derived extra
        # sleep.
        sleep(daq.config['begin_sleep'])
        if wait:
            daq.wait()
            if end_run:
                daq.end_run()
        if end_run and not wait:
            threading.Thread(target=daq._ender_thread, args=()).start()
        return status
    except KeyboardInterrupt:
            status = False
            return status

configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=None)

Configure all four laser shutters

True means that the fiber will be used and the shutter is removed. False means that the fiber will be blocked and the shutter is inserted - default for evo laser fiber1, fiber2, fiber3 None means that the shutter will not be changed - default for opo laser

Parameters

fiber1: bool Controls evo_shutter1

bool

Controls evo_shutter2

bool

Controls evo_shutter3

bool

Controls opo_shutter

Source code in mfx/yano.py

def configure_shutters(self, fiber1=False, fiber2=False, fiber3=False, free_space=None):
    """
    Configure all four laser shutters

    True means that the fiber will be used and the shutter is removed.
    False means that the fiber will be blocked and the shutter is inserted 
       - default for evo laser fiber1, fiber2, fiber3
    None means that the shutter will not be changed
       - default for opo laser

    Parameters
    ----------
    fiber1: bool
        Controls ``evo_shutter1``

    fiber2: bool
        Controls ``evo_shutter2``

    fiber3: bool
        Controls ``evo_shutter3``

    free_space: bool
        Controls ``opo_shutter``
    """
    from time import sleep
    for state, shutter in zip((fiber1, fiber2, fiber3, free_space),
                              (self.evo_shutter1, self.evo_shutter2,
                               self.evo_shutter3, self.opo_shutter)):
        if state is not None:
            if state == True or state == 'OUT' or state == 2:
                shutter('OUT')
            else:
                shutter('IN')
    #logger.info("Shutters set to fiber1=%s, fiber2=%s, fiber3=%s, free_space=%s", fiber1, fiber2, fiber3, free_space)
    sleep(1)
    return

get_delay()

Reads the current delay in ns

Parameters

delay: float Requested laser delay in nanoseconds.

Source code in mfx/yano.py

def get_delay(self):
    """
    Reads the current delay in ns

    Parameters
    ----------
    delay: float
        Requested laser delay in nanoseconds.
    """
    import logging
    logger = logging.getLogger(__name__)
    if self.opo.eventcode.get() == self.opo_ec_long:
        opo_delay = self.opo.ns_delay.get() - 1e9/120
    else:
        opo_delay = self.opo.ns_delay.get()
    delay = self.opo_time_zero - opo_delay 
    logger.info(self._delaystr(delay))
    return delay

post(sample='?', run_number=None, post=False, inspire=False, add_note='')

Posts a message to the elog

Parameters

sample: str, optional Sample Name

int, optional

Run Number. By default this is read off of the DAQ

bool, optional

set True to record/post message to elog

bool, optional

Set false by default because it makes Sandra sad. Set True to inspire

string, optional

adds additional note to elog message

Source code in mfx/yano.py

def post(self, sample='?', run_number=None, post=False, inspire=False, add_note=''):
    """
    Posts a message to the elog

    Parameters
    ----------
    sample: str, optional
        Sample Name

    run_number: int, optional
        Run Number. By default this is read off of the DAQ

    post: bool, optional
        set True to record/post message to elog

    inspire: bool, optional
        Set false by default because it makes Sandra sad. Set True to inspire

    add_note: string, optional
        adds additional note to elog message 
    """
    from mfx.db import daq, elog
    from mfx.autorun import quote
    post_template = """\
    Run Number {}: {}

    {}

    While the laser shutters are:
    EVO fiber 1 ->  {}
    EVO fiber 2 ->  {}
    EVO fiber 3 ->  {}
    OPO Shutter ->  {}
    """
    if add_note!='':
        add_note = '\n' + add_note
    if inspire:
        comment = f"Running {sample}\n{quote()['quote']}{add_note}"
    else:
        comment = f"Running {sample}{add_note}"
    delay = self.get_delay()
    if run_number is None:
        run_number = daq.run_number()
    info = [run_number, comment, self._delaystr(delay)]
    info.extend(self.shutter_status)
    post_msg = post_template.format(*info)
    print('\n' + post_msg + '\n')
    if post:
        elog.post(msg=post_msg, run=(run_number))
    return post_msg

set_delay(delay)

Set the delay

Parameters

delay: float Requested laser delay in nanoseconds.

Source code in mfx/yano.py

def set_delay(self, delay):
    """
    Set the delay

    Parameters
    ----------
    delay: float
        Requested laser delay in nanoseconds.
    """
    import logging
    logger = logging.getLogger(__name__)
    # Determine event code of inhibit pulse
    logger.info("Setting delay %s ns (%s us)", delay, delay/1000.)
    self.delay = delay
    opo_delay = self.opo_time_zero - delay
    opo_ec = self.opo_ec_short
    if delay > self.opo_time_zero + 1e9/120:
        opo_delay += 2e9/120
        opo_ec = self.opo_ec_longer
        logger.info('Laser is 2 buckets before the beam')
    elif delay > self.opo_time_zero:
        opo_delay += 1e9/120
        opo_ec = self.opo_ec_long
        logger.info('Laser is 1 bucket before the beam')
    else:
        logger.info('Laser is in the same bucket as the beam')      


    self.opo.ns_delay.put(opo_delay)
    logger.info("Setting OPO delay %s ns", opo_delay)
    self.opo.eventcode.put(opo_ec)
    logger.info("Setting OPO ec %s", opo_ec)
    logger.info(self._delaystr(delay))
    return

yano_run(sample='?', run_length=300, record=True, runs=5, inspire=False, daq_delay=5, picker=None, fiber=-1, free_space=None, laser_delay=None)

Perform a single run of the experiment

Parameters

sample: str, optional Sample Name

int, optional

number of seconds for run 300 is default

bool, optional

set True to record

int, optional

number of runs 5 is default

bool, optional

Set false by default because it makes Sandra sad. Set True to inspire

int, optional

delay time between runs. Default is 5 second but increase is the DAQ is being slow.

str, optional

If 'open' it opens pp before run starts. If 'flip' it flipflops before run starts

int, optional

Number of laser fibers. Default is -1. See configure_shutters for more information

bool, optional

Sets the free_space laser shutter to Closed (False) or Open (True). Default is None.

float

Requested laser delay in nanoseconds.

Note

0: (fiber1=False, fiber2=False, fiber3=False) 1: (fiber1=False, fiber2=False, fiber3=True) 2: (fiber1=False, fiber2=True, fiber3=True) 3: (fiber1=True, fiber2=True, fiber3=True)

For alternative laser configurations either use configure_shutters to set parameters

Source code in mfx/yano.py

def yano_run(self, sample='?', run_length=300, record=True, runs=5, inspire=False, daq_delay=5, picker=None, fiber=-1, free_space=None, laser_delay=None):
    """
    Perform a single run of the experiment

    Parameters
    ----------
    sample: str, optional
        Sample Name

    run_length: int, optional
        number of seconds for run 300 is default

    record: bool, optional
        set True to record

    runs: int, optional
        number of runs 5 is default

    inspire: bool, optional
        Set false by default because it makes Sandra sad. Set True to inspire

    daq_delay: int, optional
        delay time between runs. Default is 5 second but increase is the DAQ is being slow.

    picker: str, optional
        If 'open' it opens pp before run starts. If 'flip' it flipflops before run starts

    fiber: int, optional
        Number of laser fibers. Default is -1. See ``configure_shutters`` for more
        information

    free_space: bool, optional
        Sets the free_space laser shutter to Closed (False) or Open (True). Default is None.

    laser_delay: float
        Requested laser delay in nanoseconds.
    Note
    ----
    0: (fiber1=False, fiber2=False, fiber3=False)
    1: (fiber1=False, fiber2=False, fiber3=True)
    2: (fiber1=False, fiber2=True, fiber3=True)
    3: (fiber1=True, fiber2=True, fiber3=True)

    For alternative laser configurations either use ``configure_shutters`` to set parameters
    """
    import logging
    logger = logging.getLogger(__name__)
    from time import sleep
    from mfx.db import daq, pp
    from mfx.autorun import quote

    # Configure the shutters
    if fiber == 0:
        self.fiber_0()
    elif fiber == 1:
        self.fiber_1()
    elif fiber == 2:
        self.fiber_2()
    elif fiber == 3:
        self.fiber_3()
    else:
        logger.warning("No proper fiber number set so defaulting to ``configure_shutters`` settings.")

    if free_space is not None:
        if free_space == True or str(
            free_space).lower()==str('out') or int(
                free_space) == 2 or str(
                    free_space).lower()==str('open'):
            self.opo_shutter('OUT')
        else:
            self.opo_shutter('IN')

    if laser_delay is not None:
        self.set_delay(laser_delay)
    delay = self.get_delay()
    logger.info(self._delaystr(delay))

    if sample.lower()=='water' or sample.lower()=='h2o':
        inspire=True
    if picker=='open':
        pp.open()
    if picker=='flip':
        pp.flipflop()

    for i in range(runs):
        logger.info(f"Run Number {daq.run_number() + 1} Running {sample}......{quote()['quote']}")
        run_number = daq.run_number() + 1
        status = self.begin(duration = run_length, record = record, wait = True, end_run = True)
        if status is False:
            pp.close()
            self.post(sample, run_number, record, inspire, 'Run ended prematurely. Probably sample delivery problem')
            self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=False)
            logger.warning("[*] Stopping Run and exiting???...")
            sleep(5)
            daq.stop()
            daq.disconnect()
            logger.warning('Run ended prematurely. Probably sample delivery problem')
            break

        self.post(sample, run_number, record, inspire)
        try:
            sleep(daq_delay)
        except KeyboardInterrupt:
            pp.close()
            self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=False)
            logger.warning("[*] Stopping Run and exiting???...")
            sleep(5)
            daq.disconnect()
            status = False
            if status is False:
                logger.warning('Run ended prematurely. Probably sample delivery problem')
                break
    if status:
        pp.close()
        self.configure_shutters(fiber1=False, fiber2=False, fiber3=False, free_space=False)
        daq.end_run()
        daq.disconnect()
        logger.warning('Finished with all runs thank you for choosing the MFX beamline!\n')