incorrect-context-processing-in-task-executor

In async task executor context of wrong type (dict instead of RequestContext) is used for notification calls.

2014-10-15 14:29:51.177 22692 DEBUG magnetodb.common.cassandra.cluster_handler [-] Executing query CREATE TABLE "u_554225271b6e42f6bd85a18b817564ec"."u_d.d" ("u_hash" text,dyn_attr_dat map<text, blob>,dyn_ attr_typ map<text, text>,attr_exist map<text, int>,PRIMARY KEY ("u_hash")) execute_query /opt/stack/magnetodb/magnetodb/common/cassandra/cluster_handler.py:113 2014-10-15 14:29:51.184 22692 ERROR magnetodb.common.cassandra.cluster_handler [-] Error executing query CREATE TABLE "u_554225271b6e42f6bd85a18b817564ec"."u_d.d" ("u_hash" text,dyn_attr_dat map<text, blob >,dyn_attr_typ map<text, text>,attr_exist map<text, int>,PRIMARY KEY ("u_hash")):code=2200 [Invalid query] message=""u_d.d" is not a valid column family name (must be alphanumeric character only: [0-9A-Za- z]+)"
 Traceback (most recent call last): File "/opt/stack/magnetodb/magnetodb/common/cassandra/cluster_handler.py", line 117, in execute_query return self.__session.execute(query) File "/usr/local/lib/python2.7/dist-packages/cassandra/cluster.py", line 1281, in execute result = future.result(timeout) File "/usr/local/lib/python2.7/dist-packages/cassandra/cluster.py", line 2771, in result raise self._final_exception InvalidRequest: code=2200 [Invalid query] message=""u_d.d" is not a valid column family name (must be alphanumeric character only: [0-9A-Za-z]+)" 2014-10-15 14:29:51.184 22692 INFO magnetodb.common.probe [-] PROBE: magnetodb.storage.driver.cassandra.cassandra_impl.create_table, <_MainThread(MainThread, started 140553735980864)>, finished, 1622.34616 28 ms 2014-10-15 14:29:51.185 22692 ERROR oslo.messaging.rpc.dispatcher [-] Exception during message handling: 'dict' object has no attribute 'to_dict' Traceback (most recent call last): File "/usr/local/lib/python2.7/dist-packages/oslo/messaging/rpc/dispatcher.py", line 134, in _dispatch_and_reply incoming.message)) File "/usr/local/lib/python2.7/dist-packages/oslo/messaging/rpc/dispatcher.py", line 177, in _dispatch return self._do_dispatch(endpoint, method, ctxt, args) File "/usr/local/lib/python2.7/dist-packages/oslo/messaging/rpc/dispatcher.py", line 123, in _do_dispatch result = getattr(endpoint, method)(ctxt, **new_args) File "/opt/stack/magnetodb/bin/magnetodb-async-task-executor", line 117, in create message=e.message File "/usr/local/lib/python2.7/dist-packages/oslo/messaging/notify/notifier.py", line 256, in error self._notify(ctxt, event_type, payload, 'ERROR') File "/usr/local/lib/python2.7/dist-packages/oslo/messaging/notify/notifier.py", line 166, in _notify ctxt = self._serializer.serialize_context(ctxt) File "/opt/stack/magnetodb/magnetodb/notifier/__init__.py", line 121, in serialize_context return context.to_dict() AttributeError: 'dict' object has no attribute 'to_dict'