We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f7a6392 commit a7251b7Copy full SHA for a7251b7
1 file changed
sqlalchemy_opentracing/__init__.py
@@ -1,4 +1,4 @@
1
-from sqlalchemy.event import listen
+from sqlalchemy.event import listen, remove
2
3
g_tracer = None
4
@@ -44,6 +44,15 @@ def register_connectable(obj):
44
listen(obj, 'after_cursor_execute', _after_cursor_handler)
45
listen(obj, 'handle_error', _error_handler)
46
47
+def unregister_connectable(obj):
48
+ '''
49
+ Remove a connectable from having its events being
50
+ traced.
51
52
+ remove(obj, 'before_cursor_execute', _before_cursor_handler)
53
+ remove(obj, 'after_cursor_execute', _after_cursor_handler)
54
+ remove(obj, 'handle_error', _error_handler)
55
+
56
def _get_operation_name(stmt_obj):
57
return stmt_obj.__visit_name__
58
0 commit comments