Problem after today deployment

[rixssix]

Hi All,

I tried to run the beamlilne_align_v2() alignment and received this error

---

KeyError Traceback (most recent call last)
~/src/bluesky/bluesky/run_engine.py in _create(self, msg)
1638 try:
-> 1639 current_run = self._run_bundlers[run_key]
1640 except KeyError as ke:

KeyError: None

The above exception was the direct cause of the following exception:

IllegalMessageSequence Traceback (most recent call last)
in
----> 1 RE(beamline_align_v2())

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

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

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

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

~/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)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # 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 plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/src/bluesky/bluesky/preprocessors.py in plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/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

~/src/bluesky/bluesky/preprocessors.py in plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/src/bluesky/bluesky/preprocessors.py in plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/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 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/preprocessors.py in plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/src/bluesky/bluesky/utils.py in single_gen(msg)
137 the input message
138 '''
--> 139 return (yield msg)
140
141

~/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/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/preprocessors.py in plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/src/bluesky/bluesky/utils.py in single_gen(msg)
137 the input message
138 '''
--> 139 return (yield msg)
140
141

~/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/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/preprocessors.py in plan_mutator(plan, msg_proc)
76 # if we have a stashed exception, pass it along
77 try:
---> 78 msg = plan_stack[-1].throw(exception)
79 except StopIteration as e:
80 # discard the exhausted generator

~/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()
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
807 for obj in devices:

~/src/bluesky/bluesky/plan_stubs.py in create(name)
39 :func:bluesky.plan_stubs.save
40 """
---> 41 return (yield Msg('create', name=name))
42
43

~/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)
1409 # exceptions (coming in via throw) can be
1410 # raised
-> 1411 new_response = await coro(msg)
1412
1413 # special case CancelledError and let the outer

~/src/bluesky/bluesky/run_engine.py in _create(self, msg)
1641 raise IllegalMessageSequence("Cannot bundle readings without "
1642 "an open run. That is, 'create' must "
-> 1643 "be preceded by 'open_run'.") from ke
1644 return (await current_run.create(msg))
1645

IllegalMessageSequence: Cannot bundle readings without an open run. That is, 'create' must be preceded by 'open_run'.

Any suggestions?

[tacaswell]

Did you roll back to the old enviroment?

[rixssix]

No I changed the function removing the line that was added.