- %{query_time: query_time} = _measurements,
- %{source: source, query: query, params: query_params, repo: repo} = _metadata,
- _config
- )
- when query_time > 500_000 and source not in [nil, "oban_jobs"] do
- {:current_stacktrace, stacktrace} = Process.info(self(), :current_stacktrace)
+ %{query_time: query_time} = measurements,
+ %{source: source} = metadata,
+ config
+ ) do
+ logging_config = Pleroma.Config.get([:telemetry, :slow_queries_logging], [])
+
+ if logging_config[:enabled] &&
+ logging_config[:min_duration] &&
+ query_time > logging_config[:min_duration] and
+ (is_nil(logging_config[:exclude_sources]) or
+ source not in logging_config[:exclude_sources]) do
+ log_slow_query(measurements, metadata, config)
+ else
+ :ok
+ end
+ end