Skip to content

Commit 7af26f1

Browse files
author
Emanuele Palazzetti
committed
[core] add deprecation module
1 parent e439a52 commit 7af26f1

File tree

12 files changed

+86
-40
lines changed

12 files changed

+86
-40
lines changed

ddtrace/contrib/cassandra/session.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,9 @@
1010
# project
1111
from ddtrace import Pin
1212
from ddtrace.compat import stringify
13-
from ...util import deep_getattr, deprecated
13+
14+
from ...utils.deprecation import deprecated
15+
from ...util import deep_getattr
1416
from ...ext import net, cassandra as cassx, errors
1517

1618
log = logging.getLogger(__name__)
@@ -257,7 +259,7 @@ def _sanitize_query(span, query):
257259
# DEPRECATED
258260
#
259261

260-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
262+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
261263
def get_traced_cassandra(*args, **kwargs):
262264
return _get_traced_cluster(*args, **kwargs)
263265

ddtrace/contrib/elasticsearch/transport.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,18 @@
11
from elasticsearch import Transport
22
from elasticsearch.exceptions import TransportError
33

4-
from .quantize import quantize
54
from . import metadata
5+
from .quantize import quantize
6+
7+
from ...utils.deprecation import deprecated
68
from ...compat import urlencode
79
from ...ext import AppTypes, http
8-
from ...util import deprecated
910

1011
DEFAULT_SERVICE = 'elasticsearch'
1112
SPAN_TYPE = 'elasticsearch'
1213

1314

14-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
15+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
1516
def get_traced_transport(datadog_tracer, datadog_service=DEFAULT_SERVICE):
1617

1718
datadog_tracer.set_service_info(

ddtrace/contrib/mongoengine/patch.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import mongoengine
22

33
from .trace import WrappedConnect
4-
from ddtrace.util import deprecated
4+
from ...utils.deprecation import deprecated
55

66
# Original connect function
77
_connect = mongoengine.connect
@@ -13,7 +13,7 @@ def patch():
1313
def unpatch():
1414
setattr(mongoengine, 'connect', _connect)
1515

16-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
16+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
1717
def trace_mongoengine(*args, **kwargs):
1818
return _connect
1919

ddtrace/contrib/mysql/tracers.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
import mysql.connector
22

3-
from ddtrace.util import deprecated
3+
from ...utils.deprecation import deprecated
44

5-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
5+
6+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
67
def get_traced_mysql_connection(*args, **kwargs):
78
return mysql.connector.MySQLConnection

ddtrace/contrib/psycopg/connection.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,13 +9,13 @@
99
from ...ext import net
1010
from ...ext import sql
1111
from ...ext import AppTypes
12-
from ...util import deprecated
12+
from ...utils.deprecation import deprecated
1313

1414
# 3p
1515
from psycopg2.extensions import connection, cursor
1616

1717

18-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
18+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
1919
def connection_factory(tracer, service="postgres"):
2020
""" Return a connection factory class that will can be used to trace
2121
postgres queries.

ddtrace/contrib/pymongo/client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,11 @@
99

1010
# project
1111
import ddtrace
12+
from ...utils.deprecation import deprecated
1213
from ...compat import iteritems
1314
from ...ext import AppTypes
1415
from ...ext import mongo as mongox
1516
from ...ext import net as netx
16-
from ...util import deprecated
1717
from .parse import parse_spec, parse_query, parse_msg
1818

1919
# Original Client class
@@ -22,7 +22,7 @@
2222
log = logging.getLogger(__name__)
2323

2424

25-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
25+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
2626
def trace_mongo_client(client, tracer, service=mongox.TYPE):
2727
tracer.set_service_info(
2828
service=service,

ddtrace/contrib/pymysql/tracers.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
import pymysql.connections
22

3-
from ddtrace.util import deprecated
3+
from ...utils.deprecation import deprecated
44

5-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
5+
6+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
67
def get_traced_pymysql_connection(*args, **kwargs):
78
return pymysql.connections.Connection

ddtrace/contrib/redis/tracers.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,20 @@
11
from redis import StrictRedis
22

3-
from ...util import deprecated
3+
from ...utils.deprecation import deprecated
4+
45

56
DEFAULT_SERVICE = 'redis'
67

78

8-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
9+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
910
def get_traced_redis(ddtracer, service=DEFAULT_SERVICE, meta=None):
1011
return _get_traced_redis(ddtracer, StrictRedis, service, meta)
1112

12-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
13+
14+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
1315
def get_traced_redis_from(ddtracer, baseclass, service=DEFAULT_SERVICE, meta=None):
1416
return _get_traced_redis(ddtracer, baseclass, service, meta)
1517

18+
1619
def _get_traced_redis(ddtracer, baseclass, service, meta):
1720
return baseclass
18-
Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
from sqlite3 import Connection
22

3-
from ddtrace.util import deprecated
3+
from ...utils.deprecation import deprecated
44

5-
@deprecated(message='Use patching instead (see the docs).', version='0.6.0')
5+
6+
@deprecated(message='Use patching instead (see the docs).', version='1.0.0')
67
def connection_factory(*args, **kwargs):
78
return Connection

ddtrace/util.py

Lines changed: 1 addition & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1,24 +1,6 @@
11
import os
2-
import inspect
3-
import logging
42
import wrapt
5-
6-
from functools import wraps
7-
8-
9-
def deprecated(message='', version=None):
10-
"""Function decorator to report a deprecated function"""
11-
def decorator(func):
12-
@wraps(func)
13-
def wrapper(*args, **kwargs):
14-
logger = logging.getLogger(func.__module__)
15-
logger.warning("%s is deprecated and will be remove in future versions%s. %s",
16-
func.__name__,
17-
' (%s)' % version if version else '',
18-
message)
19-
return func(*args, **kwargs)
20-
return wrapper
21-
return decorator
3+
import inspect
224

235

246
def deep_getattr(obj, attr_string, default=None):

0 commit comments

Comments
 (0)