Zy Filemanager

📁 File Browser

Name	Size	Permissions	Actions
📁 __pycache__	DIR	0755	🗑️
📁 django	DIR	0755	🗑️
📁 grpc	DIR	0755	🗑️
📁 opentelemetry	DIR	0755	🗑️
📁 redis	DIR	0755	🗑️
📁 spark	DIR	0755	🗑️
📄 __init__.py (6,827 bytes)	6.67 KB	0644	✍️ ⬇️ 🗑️
📄 _wsgi_common.py (4,537 bytes)	4.43 KB	0644	✍️ ⬇️ 🗑️
📄 aiohttp.py (11,553 bytes)	11.28 KB	0644	✍️ ⬇️ 🗑️
📄 argv.py (963 bytes)	963 B	0644	✍️ ⬇️ 🗑️
📄 arq.py (6,737 bytes)	6.58 KB	0644	✍️ ⬇️ 🗑️
📄 asgi.py (11,821 bytes)	11.54 KB	0644	✍️ ⬇️ 🗑️
📄 asyncio.py (3,049 bytes)	2.98 KB	0644	✍️ ⬇️ 🗑️
📄 atexit.py (1,846 bytes)	1.8 KB	0644	✍️ ⬇️ 🗑️
📄 aws_lambda.py (15,815 bytes)	15.44 KB	0644	✍️ ⬇️ 🗑️
📄 beam.py (5,689 bytes)	5.56 KB	0644	✍️ ⬇️ 🗑️
📄 boto3.py (4,542 bytes)	4.44 KB	0644	✍️ ⬇️ 🗑️
📄 bottle.py (6,471 bytes)	6.32 KB	0644	✍️ ⬇️ 🗑️
📄 celery.py (19,100 bytes)	18.65 KB	0644	✍️ ⬇️ 🗑️
📄 chalice.py (4,769 bytes)	4.66 KB	0644	✍️ ⬇️ 🗑️
📄 cloud_resource_context.py (6,755 bytes)	6.6 KB	0644	✍️ ⬇️ 🗑️
📄 dedupe.py (1,184 bytes)	1.16 KB	0644	✍️ ⬇️ 🗑️
📄 excepthook.py (2,260 bytes)	2.21 KB	0644	✍️ ⬇️ 🗑️
📄 executing.py (2,041 bytes)	1.99 KB	0644	✍️ ⬇️ 🗑️
📄 falcon.py (7,984 bytes)	7.8 KB	0644	✍️ ⬇️ 🗑️
📄 fastapi.py (4,496 bytes)	4.39 KB	0644	✍️ ⬇️ 🗑️
📄 flask.py (7,907 bytes)	7.72 KB	0644	✍️ ⬇️ 🗑️
📄 gcp.py (8,213 bytes)	8.02 KB	0644	✍️ ⬇️ 🗑️
📄 gnu_backtrace.py (2,930 bytes)	2.86 KB	0644	✍️ ⬇️ 🗑️
📄 httpx.py (5,005 bytes)	4.89 KB	0644	✍️ ⬇️ 🗑️
📄 huey.py (4,700 bytes)	4.59 KB	0644	✍️ ⬇️ 🗑️
📄 logging.py (9,181 bytes)	8.97 KB	0644	✍️ ⬇️ 🗑️
📄 loguru.py (3,051 bytes)	2.98 KB	0644	✍️ ⬇️ 🗑️
📄 modules.py (2,110 bytes)	2.06 KB	0644	✍️ ⬇️ 🗑️
📄 pure_eval.py (4,554 bytes)	4.45 KB	0644	✍️ ⬇️ 🗑️
📄 pymongo.py (6,007 bytes)	5.87 KB	0644	✍️ ⬇️ 🗑️
📄 pyramid.py (7,442 bytes)	7.27 KB	0644	✍️ ⬇️ 🗑️
📄 quart.py (7,377 bytes)	7.2 KB	0644	✍️ ⬇️ 🗑️
📄 rq.py (5,411 bytes)	5.28 KB	0644	✍️ ⬇️ 🗑️
📄 sanic.py (11,326 bytes)	11.06 KB	0644	✍️ ⬇️ 🗑️
📄 serverless.py (1,975 bytes)	1.93 KB	0644	✍️ ⬇️ 🗑️
📄 socket.py (2,945 bytes)	2.88 KB	0644	✍️ ⬇️ 🗑️
📄 sqlalchemy.py (4,244 bytes)	4.14 KB	0644	✍️ ⬇️ 🗑️
📄 starlette.py (23,211 bytes)	22.67 KB	0644	✍️ ⬇️ 🗑️
📄 starlite.py (10,089 bytes)	9.85 KB	0644	✍️ ⬇️ 🗑️
📄 stdlib.py (8,251 bytes)	8.06 KB	0644	✍️ ⬇️ 🗑️
📄 threading.py (2,937 bytes)	2.87 KB	0644	✍️ ⬇️ 🗑️
📄 tornado.py (7,342 bytes)	7.17 KB	0644	✍️ ⬇️ 🗑️
📄 trytond.py (1,745 bytes)	1.7 KB	0644	✍️ ⬇️ 🗑️
📄 wsgi.py (9,581 bytes)	9.36 KB	0644	✍️ ⬇️ 🗑️

✍️ Editing: sqlalchemy.py

            File: /opt/cloudlinux/venv/lib/python3.11/site-packages/sentry_sdk/integrations/sqlalchemy.py

            Size: 4.14 KB | 
            Last Modified: 2026-01-20 20:01:48        

from __future__ import absolute_import

from sentry_sdk._compat import text_type
from sentry_sdk._types import TYPE_CHECKING
from sentry_sdk.consts import SPANDATA
from sentry_sdk.hub import Hub
from sentry_sdk.integrations import Integration, DidNotEnable
from sentry_sdk.tracing_utils import record_sql_queries

from sentry_sdk.utils import parse_version

try:
    from sqlalchemy.engine import Engine  # type: ignore
    from sqlalchemy.event import listen  # type: ignore
    from sqlalchemy import __version__ as SQLALCHEMY_VERSION  # type: ignore
except ImportError:
    raise DidNotEnable("SQLAlchemy not installed.")

if TYPE_CHECKING:
    from typing import Any
    from typing import ContextManager
    from typing import Optional

from sentry_sdk.tracing import Span

class SqlalchemyIntegration(Integration):
    identifier = "sqlalchemy"

@staticmethod
    def setup_once():
        # type: () -> None

version = parse_version(SQLALCHEMY_VERSION)

if version is None:
            raise DidNotEnable(
                "Unparsable SQLAlchemy version: {}".format(SQLALCHEMY_VERSION)
            )

if version < (1, 2):
            raise DidNotEnable("SQLAlchemy 1.2 or newer required.")

listen(Engine, "before_cursor_execute", _before_cursor_execute)
        listen(Engine, "after_cursor_execute", _after_cursor_execute)
        listen(Engine, "handle_error", _handle_error)

def _before_cursor_execute(
    conn, cursor, statement, parameters, context, executemany, *args
):
    # type: (Any, Any, Any, Any, Any, bool, *Any) -> None
    hub = Hub.current
    if hub.get_integration(SqlalchemyIntegration) is None:
        return

ctx_mgr = record_sql_queries(
        hub,
        cursor,
        statement,
        parameters,
        paramstyle=context and context.dialect and context.dialect.paramstyle or None,
        executemany=executemany,
    )
    context._sentry_sql_span_manager = ctx_mgr

span = ctx_mgr.__enter__()

if span is not None:
        _set_db_data(span, conn)
        context._sentry_sql_span = span

def _after_cursor_execute(conn, cursor, statement, parameters, context, *args):
    # type: (Any, Any, Any, Any, Any, *Any) -> None
    ctx_mgr = getattr(
        context, "_sentry_sql_span_manager", None
    )  # type: Optional[ContextManager[Any]]

if ctx_mgr is not None:
        context._sentry_sql_span_manager = None
        ctx_mgr.__exit__(None, None, None)

def _handle_error(context, *args):
    # type: (Any, *Any) -> None
    execution_context = context.execution_context
    if execution_context is None:
        return

span = getattr(execution_context, "_sentry_sql_span", None)  # type: Optional[Span]

if span is not None:
        span.set_status("internal_error")

# _after_cursor_execute does not get called for crashing SQL stmts. Judging
    # from SQLAlchemy codebase it does seem like any error coming into this
    # handler is going to be fatal.
    ctx_mgr = getattr(
        execution_context, "_sentry_sql_span_manager", None
    )  # type: Optional[ContextManager[Any]]

if ctx_mgr is not None:
        execution_context._sentry_sql_span_manager = None
        ctx_mgr.__exit__(None, None, None)

# See: https://docs.sqlalchemy.org/en/20/dialects/index.html
def _get_db_system(name):
    # type: (str) -> Optional[str]
    name = text_type(name)

if "sqlite" in name:
        return "sqlite"

if "postgres" in name:
        return "postgresql"

if "mariadb" in name:
        return "mariadb"

if "mysql" in name:
        return "mysql"

if "oracle" in name:
        return "oracle"

return None

def _set_db_data(span, conn):
    # type: (Span, Any) -> None
    db_system = _get_db_system(conn.engine.name)
    if db_system is not None:
        span.set_data(SPANDATA.DB_SYSTEM, db_system)

db_name = conn.engine.url.database
    if db_name is not None:
        span.set_data(SPANDATA.DB_NAME, db_name)

server_address = conn.engine.url.host
    if server_address is not None:
        span.set_data(SPANDATA.SERVER_ADDRESS, server_address)

server_port = conn.engine.url.port
    if server_port is not None:
        span.set_data(SPANDATA.SERVER_PORT, server_port)

↩️ Back

Zy Filemanager

📁 File Browser

📤 Upload Files

Single File

Multiple Files

ZIP Extract

➕ Create New

New Folder

New File

✍️ Editing: sqlalchemy.py

Backup Management