PostPlan breaks - Githubissues

Hi All, The postplan gives us this error

+-----------+------------+ | seq_num | time | +-----------+------------+ /opt/conda_envs/collection-2020-1.0rc1/lib/python3.7/site-packages/databroker/assets/core.py:155: UserWarning: Ignoring attempt to insert Resource with duplicate uid, assuming that both ophyd and bluesky attempted to insert this document. Remove the Registry (reg parameter) from your ophyd instance to remove this warning. warnings.warn("Ignoring attempt to insert Resource with duplicate " | 1 | 15:50:48.2 | +-----------+------------+ generator count ['29ea576a'] (scan num: 93637) End-of-run baseline readings: +--------------------------------+--------------------------------+ | ring_curr | 399.13759941971904 | | gc_tcg_pressure | 0.001 | | epu1_gap_readback | 21.9477 | | epu1_phase_readback | 28.4999 | | feslt_hc_readback | -0.03978000000000015 | | feslt_vc_readback | -0.1999900000000001 | | feslt_hg_readback | 1.9997200000000004 | | feslt_vg_readback | 1.9999000000000002 | | m1_x | 0.50055 | | m1_pit | 1797.3085 | | m1_rol | 3911.4801 | | pgm_cff | 3.9406000000000003 | | pgm_en | 530.0 | | pgm_grx | 61.0 | | pgm_m2pit | 87.21760733549651 | | pgm_grpit | 85.56069670742103 | | pgm_m3slt_hs | -37.802185 | | pgm_m3slt_ha | -17.2005625 | | m3slt_hg | -17.2006 | | m3slt_hc | -46.4028 | | m3slt_vg | -3853.2999 | | m3slt_vc | -1926.6489000000001 | | m3slt_hs | -37.802185 | | m3slt_ha | -17.2005625 | | m3slt_vs | 0.000635 | | m3slt_va | -3853.2998562499997 | | m3diag_y | -1.000521875 | | m3_x | 1.0 | | m3_y | 0.0 | | m3_z | 1.0 | | m3_yaw | -0.5 | | m3_pit | -0.7546950000000001 | | m3_rol | 0.14500000000000002 | | extslt_hg | 149.9977 | | extslt_vg | 10.9994 | | extslt_hc | -5.3574 | | gcdiag_y | -0.9999265625 | | m4_diag1 | -0.9999265625 | | m4slt_hg | 7.000699999999999 | | m4slt_hc | -1.8001999999999998 | | m4slt_vg | 1.9996 | | m4slt_vc | -0.19740000000000002 | | m4slt_inb | 5.79945 | | m4slt_out | 0.20025 | | m4slt_bot | -1.1971499999999993 | | m4slt_top | 0.8024500000000003 | | m4_x | 0.2601 | | m4_y | 94.95 | | m4_z | -5.550000000000001 | | m4_yaw | -0.70735 | | m4_pit | -4.104500000000001 | | m4_rol | -0.16425 | | cryo_x | 19.08670000000029 | | cryo_y | 58.99655000000007 | | cryo_z | 12.150000000000091 | | cryo_t | 30.00019448179998 | | stemp_ctrl1_readback | 110.0 | | stemp_ctrl2_readback | 300.0 | | ow | -9.930346093490016 | | m5_x | -0.37 | | m5_y | 0.0 | | m5_z | -0.4 | | m5_yaw | 0.0 | | m5_pit | 380.0 | | m5_rol | -1000.0 | | m5mask_y | 21.0 | | m6_msk | 89.0 | | m6_z | 105.99980000000001 | | m6_pit | 1.4320986789199999 | | espgm_m7pit | 6.470238935239999 | | espgm_grpit | 7.62262933172 | | espgmmask_y | 0.0 | | oc_y | 0.0 | | oc_z | 5.054700000000025 | | oc_roll | 0.0 | | oc_twoth | 149.97916024740002 | | oc_wlin | -1.1435500000000047 | | oc_wlot | -1.1432499999999663 | | dcslt_hg | 0.0 | | dcslt_hc | 0.0 | | dcslt_vg | 0.0 | | dcslt_vc | 0.0 | | dcslt_inb | 18.001 | | dcslt_out | 47.0 | | dcslt_bot | 13.501000000000001 | | dcslt_top | 15.999999999999996 | | dc_z | 225.49920000000003 | | dc_twoth | 149.35360505650002 | +--------------------------------+--------------------------------+

gvbt1 close 140606916789968

RedundantStaging Traceback (most recent call last) ~/science_comm/00-user_info.py in ----> 1 RE(rixs_one_energy_1(2,30,1,530,11,'test'))

~/src/bluesky/bluesky/run_engine.py in call(self, *args, **metadata_kw) 790 self._task_fut.add_done_callback(set_blocking_event) 791 --> 792 self._resume_task(init_func=_build_task) 793 794 if self._interrupted:

~/src/bluesky/bluesky/run_engine.py in _resume_task(self, init_func) 914 if (exc is not None 915 and not isinstance(exc, _RunEnginePanic)): --> 916 raise exc 917 918 def install_suspender(self, suspender):

~/src/bluesky/bluesky/run_engine.py in _run(self) 1481 exit_reason = str(err) 1482 self.log.exception("Run aborted") -> 1483 raise err 1484 finally: 1485 if not exit_reason:

~/src/bluesky/bluesky/run_engine.py in _run(self) 1348 else: 1349 try: -> 1350 msg = self._plan_stack[-1].send(resp) 1351 # We have exhausted the top generator 1352 except StopIteration:

~/src/bluesky/bluesky/preprocessors.py in call(self, plan) 1305 plan = monitor_during_wrapper(plan, self.monitors) 1306 plan = baseline_wrapper(plan, self.baseline) -> 1307 return (yield from plan) 1308 1309

~/src/bluesky/bluesky/preprocessors.py in baseline_wrapper(plan, devices, name) 1160 return (yield from plan) 1161 else: -> 1162 return (yield from plan_mutator(plan, insert_baseline)) 1163 1164

~/src/bluesky/bluesky/preprocessors.py in plan_mutator(plan, msg_proc) 168 continue 169 else: --> 170 raise ex 171 # if inserting / mutating, put new generator on the stack 172 # and replace the current msg with the first element from the

~/src/bluesky/bluesky/preprocessors.py in plan_mutator(plan, msg_proc) 121 ret = result_stack.pop() 122 try: --> 123 msg = plan_stack[-1].send(ret) 124 except StopIteration as e: 125 # discard the exhausted generator

~/src/bluesky/bluesky/preprocessors.py in monitor_during_wrapper(plan, signals) 801 plan1 = plan_mutator(plan, insert_after_open) 802 plan2 = plan_mutator(plan1, insert_before_close) --> 803 return (yield from plan2) 804 805

~/src/bluesky/bluesky/preprocessors.py in fly_during_wrapper(plan, flyers) 859 plan1 = plan_mutator(plan, insert_after_open) 860 plan2 = plan_mutator(plan1, insert_before_close) --> 861 return (yield from plan2) 862 863

~/science_comm/00-user_info.py in rixs_one_energy_1(split_time, total_exp, cycles, energy, ext_vg, reason, disable_sclr_plt) 62 try: 63 print('Starting cycle {} of {}' .format((i+1),cycles)) ---> 64 yield from count(dets, num=pts, md = {'reason':'Length = '+str(np.int(pts*split_time))+' s -'+reason} ) 65 yield from mvr(cryo.y,-0.002) # if you do not want to move comment out this line 66 #yield from sleep(3)

~/src/bluesky/bluesky/plans.py in count(detectors, num, delay, per_shot, md) 75 num=num, delay=delay)) 76 ---> 77 return (yield from inner_count()) 78 79

~/src/bluesky/bluesky/utils.py in dec_inner(*inner_args, inner_kwargs) 1041 plan = gen_func(*inner_args, *inner_kwargs) 1042 plan = wrapper(plan, args, kwargs) -> 1043 return (yield from plan) 1044 return dec_inner 1045 return dec

~/src/bluesky/bluesky/preprocessors.py in stage_wrapper(plan, devices) 950 return (yield from plan) 951 --> 952 return (yield from finalize_wrapper(inner(), unstage_devices())) 953 954

~/src/bluesky/bluesky/preprocessors.py in finalize_wrapper(plan, final_plan, pause_for_debug) 507 cleanup = True 508 try: --> 509 ret = yield from plan 510 except GeneratorExit: 511 cleanup = False

~/src/bluesky/bluesky/preprocessors.py in inner() 948 def inner(): 949 yield from stage_devices() --> 950 return (yield from plan) 951 952 return (yield from finalize_wrapper(inner(), unstage_devices()))

~/src/bluesky/bluesky/preprocessors.py in run_wrapper(plan, md) 325 yield from contingency_wrapper(plan, 326 except_plan=except_plan, --> 327 else_plan=close_run) 328 return rs_uid 329

~/src/bluesky/bluesky/preprocessors.py in contingency_wrapper(plan, except_plan, else_plan, final_plan, pause_for_debug) 573 cleanup = True 574 try: --> 575 ret = yield from plan 576 except GeneratorExit: 577 cleanup = False

~/src/bluesky/bluesky/plans.py in inner_count() 73 def inner_count(): 74 return (yield from bps.repeat(partial(per_shot, detectors), ---> 75 num=num, delay=delay)) 76 77 return (yield from inner_count())

~/src/bluesky/bluesky/plan_stubs.py in repeat(plan, num, delay) 1084 yield Msg('sleep', None, d) 1085 -> 1086 return (yield from repeated_plan())

~/src/bluesky/bluesky/plan_stubs.py in repeated_plan() 1067 now = time.time() # Intercept the flow in its earliest moment. 1068 yield Msg('checkpoint') -> 1069 yield from ensure_generator(plan()) 1070 try: 1071 d = next(delay)

~/src/bluesky/bluesky/plan_stubs.py in one_shot(detectors, take_reading) 927 """ 928 yield Msg('checkpoint') --> 929 yield from take_reading(list(detectors)) 930 931

~/src/bluesky/bluesky/plan_stubs.py in trigger_and_read(devices, name) 813 from .preprocessors import rewindable_wrapper 814 return (yield from rewindable_wrapper(inner_trigger_and_read(), --> 815 rewindable)) 816 817

~/src/bluesky/bluesky/preprocessors.py in rewindable_wrapper(plan, rewindable) 691 restore_rewindable())) 692 else: --> 693 return (yield from plan) 694 695

~/src/bluesky/bluesky/plan_stubs.py in inner_trigger_and_read() 802 # Skip 'wait' if none of the devices implemented a trigger method. 803 if not no_wait: --> 804 yield from wait(group=grp) 805 yield from create(name) 806 ret = {} # collect and return readings to give plan access to them

~/src/bluesky/bluesky/plan_stubs.py in wait(group) 368 Msg('wait', None, group=group) 369 """ --> 370 return (yield Msg('wait', None, group=group)) 371 372

~/src/bluesky/bluesky/preprocessors.py in plan_mutator(plan, msg_proc) 193 try: 194 # yield out the 'current message' and collect the return --> 195 inner_ret = yield msg 196 except GeneratorExit: 197 # special case GeneratorExit. We must clean up all of our plans

~/src/bluesky/bluesky/run_engine.py in _run(self) 1325 try: 1326 msg = self._plan_stack[-1].throw( -> 1327 stashed_exception or resp) 1328 except Exception as e: 1329 # The current plan did not handle it,

~/src/bluesky/bluesky/utils.py in (.0) 116 if not isinstance(gen, PLAN_TYPES): 117 # If plan does not support .send, we must wrap it in a generator. --> 118 gen = (msg for msg in gen) 119 120 return gen

~/src/bluesky/bluesky/utils.py in single_gen(msg) 121 122 --> 123 def single_gen(msg): 124 '''Turn a single message into a plan 125

~/science_comm/00-user_info.py in beamline_align_v3_for_suspenders() 164 # multiple suspenders are tripped at the same time. 165 run_name = f'alignment-{str(uuid.uuid4())[:8]}' --> 166 yield from bpp.set_run_key_wrapper(beamline_align_v3(), run=run_name) 167 168 #@bpp.set_run_key_decorator('alignment')

~/src/bluesky/bluesky/preprocessors.py in set_run_key_wrapper(plan, run) 1330 return msg 1331 -> 1332 return (yield from msg_mutator(plan, _set_run_key)) 1333 1334 set_run_key_decorator = make_decorator(set_run_key_wrapper)

~/src/bluesky/bluesky/preprocessors.py in msg_mutator(plan, msg_proc) 243 ret = None 244 continue --> 245 ret = yield msg 246 except StopIteration as e: 247 return e.value

~/src/bluesky/bluesky/run_engine.py in _run(self) 1406 # exceptions (coming in via throw) can be 1407 # raised -> 1408 new_response = await coro(msg) 1409 1410 # special case CancelledError and let the outer

~/src/bluesky/bluesky/run_engine.py in _stage(self, msg) 2143 if not hasattr(obj, 'stage'): 2144 return [] -> 2145 result = obj.stage() 2146 self._staged.add(obj) # add first in case of failure below 2147 await self._reset_checkpoint_state_coro()

/opt/conda_envs/collection-2020-1.0rc1/lib/python3.7/site-packages/ophyd/areadetector/trigger_mixins.py in stage(self) 119 def stage(self): 120 self._acquisition_signal.subscribe(self._acquire_changed) --> 121 super().stage() 122 123 def unstage(self):

/opt/conda_envs/collection-2020-1.0rc1/lib/python3.7/site-packages/ophyd/areadetector/base.py in stage(self, *args, kwargs) 286 287 def stage(self, *args, *kwargs): --> 288 ret = super().stage(args, kwargs) 289 try: 290 self.validate_asyn_ports()

/opt/conda_envs/collection-2020-1.0rc1/lib/python3.7/site-packages/ophyd/device.py in stage(self) 516 elif self._staged == Staged.yes: 517 raise RedundantStaging("Device {!r} is already staged. " --> 518 "Unstage it first.".format(self)) 519 elif self._staged == Staged.partially: 520 raise RedundantStaging("Device {!r} has been partially staged. "

RedundantStaging: Device RIXSCam(prefix='XF:02ID1-ES{RIXSCam}:', name='rixscam', read_attrs=['xip', 'xip.count_possible_event', 'xip.count_above_threshold', 'xip.count_below_threshold', 'xip.count_neighbours', 'xip.count_event_2x2', 'xip.count_event_3x3', 'hdf5', 'hdf2'], configuration_attrs=['cam', 'cam.acquire_period', 'cam.acquire_time', 'cam.num_images', 'cam.temperature', 'cam.temperature_actual', 'cam.trigger_mode', 'centroid_enable', 'xip', 'xip.algorithm', 'xip.output_mode', 'xip.bkgd_update_mode', 'xip.bkgd_value', 'xip.sum_3x3_threshold_min', 'xip.sum_3x3_threshold_max', 'xip.hist_start', 'xip.hist_bin_width', 'xip.hist_bin_count', 'xip.source_region', 'xip.dim0_region_start', 'xip.dim0_region_size', 'xip.dim1_region_start', 'xip.dim1_region_size', 'xip.x_expansion_factor', 'xip.y_expansion_factor', 'xip.centroid_correction', 'xip.beamline_energy', 'xip.isolinear_correction', 'xip.isolinear_coefficient_x2_1', 'xip.isolinear_coefficient_x1_1', 'xip.isolinear_coefficient_x0_1', 'xip.isolinear_coefficient_x2_2', 'xip.isolinear_coefficient_x1_2', 'xip.isolinear_coefficient_x0_2', 'xip.isolinear_threshold', 'hdf5', 'hdf2', 'set_node', 'sensor_region_xsize', 'sensor_region_ysize', 'sensor_region_xstart', 'sensor_region_ystart', 'sensor_binning_x', 'sensor_binning_y', 'ccd1_hv', 'ccd2_hv']) is already staged. Unstage it first.

We are testing it and when a command is interrupted it should run the function beamline_align_v3_for_suspenders(). However it stops and produces the above error

NSLS-II / Bug-Reports

PostPlan breaks #204

gvbt1 close 140606916789968