Bases: KPFTranslatorFunction
Begins an triggered exposure by setting the kpfexpose.EXPOSE keyword
to Start. This will return immediately after. Use commands like
WaitForReadout or WaitForReady to determine when an exposure is done.
ARGS:
None
Source code in kpf/spectrograph/StartExposure.py
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87 | class StartExposure(KPFTranslatorFunction):
'''Begins an triggered exposure by setting the `kpfexpose.EXPOSE` keyword
to Start. This will return immediately after. Use commands like
WaitForReadout or WaitForReady to determine when an exposure is done.
ARGS:
=====
None
'''
@classmethod
def pre_condition(cls, args, logger, cfg):
pass
@classmethod
def perform(cls, args, logger, cfg):
expose = ktl.cache('kpfexpose', 'EXPOSE')
WaitForReady.execute({})
log.debug(f"Beginning Exposure")
expose.write('Start')
@classmethod
def post_condition(cls, args, logger, cfg):
expr = f"(kpfexpose.EXPOSE != Start)"
kpfexpose = ktl.cache('kpfexpose')
is_GREEN_ENABLED = ktl.cache('kpfconfig', 'GREEN_ENABLED').read() == 'Yes'
is_RED_ENABLED = ktl.cache('kpfconfig', 'RED_ENABLED').read() == 'Yes'
is_CA_HK_ENABLED = ktl.cache('kpfconfig', 'CA_HK_ENABLED').read() == 'Yes'
trig_targ = kpfexpose['TRIG_TARG'].read().split(',')
if 'Green' in trig_targ and is_GREEN_ENABLED:
expr += ' and ($kpfgreen.EXPSTATE != Start)'
if 'Red' in trig_targ and is_RED_ENABLED:
expr += ' and ($kpfred.EXPSTATE != Start)'
if 'Ca_HK' in trig_targ and is_CA_HK_ENABLED:
expr += ' and ($kpf_hk.EXPSTATE != Start)'
exptime = kpfexpose['EXPOSURE'].read(binary=True)
timeout = 6
left_start_state = ktl.waitFor(expr, timeout=timeout)
if left_start_state is False:
log.error(f'We are still in start state after {timeout} s')
# Figure out which detector is stuck in the start state?
if is_GREEN_ENABLED:
green_expstate = ktl.cache('kpfgreen', 'EXPSTATE').read()
log.debug(f'kpfgreen.EXPSTATE = {green_expstate}')
if is_RED_ENABLED:
red_expstate = ktl.cache('kpfred', 'EXPSTATE').read()
log.debug(f'kpfred.EXPSTATE = {red_expstate}')
if is_CA_HK_ENABLED:
cahk_expstate = ktl.cache('kpf_hk', 'EXPSTATE').read()
log.debug(f'kpf_hk.EXPSTATE = {cahk_expstate}')
# Abort the current exposure
elapsed = kpfexpose['ELAPSED'].read(binary=True)
remaining = exptime-elapsed
if remaining <= 10:
# Don't stop exposure, just wait it out
log.debug(f'Waiting out remaining {remaining} s of exposure')
time.sleep(remaining+2)
else:
log.warning('Stopping current exposure (with read out)')
kpfexpose['EXPOSE'].write('End')
time.sleep(2) # Time shim, this time is a WAG
# Now reset the offending detector
if is_GREEN_ENABLED:
if green_expstate == 'Start':
ResetGreenDetector.execute({})
if is_RED_ENABLED:
if red_expstate == 'Start':
ResetRedDetector.execute({})
if is_CA_HK_ENABLED:
if cahk_expstate == 'Start':
ResetCaHKDetector.execute({})
# Now start a fresh exposure
WaitForReady.execute({})
time.sleep(1.0) # This time shim and the WaitForReady are hacks to catch if the
WaitForReady.execute({}) # reset detector went in to readout, but we didn't know.
log.warning('Restarting exposure')
StartExposure.execute(args)
|