Disable logging of DeprecationWarnings and BrokenPipeErrors (#633)

Author: droserasprout

CHANGELOG.md

@@ -9,6 +9,8 @@ The format is based on [Keep a Changelog], and this project adheres to [Semantic
 ### Fixed
 
 - config: Fixed crash when `token_transfer` index has `from` or `to` filter.
+- cli: Don't enforce logging `DeprecationWarning` warnings.
+- cli: Fixed `BrokenPipeError` messages when interrupting with DipDup with SIGINT.
 
 ### Security
 

docs/cli-reference.md

@@ -181,7 +181,7 @@
 <section id="dipdup-run">
 <h2>run<a class="headerlink" href="#dipdup-run" title="Permalink to this heading">¶</a></h2>
 <p>Run indexer.</p>
-<p>Execution can be gracefully interrupted with <cite>Ctrl+C</cite> or <cite>SIGTERM</cite> signal.</p>
+<p>Execution can be gracefully interrupted with <cite>Ctrl+C</cite> or <cite>SIGINT</cite> signal.</p>
 <div class="highlight-shell notranslate"><div class="highlight"><pre><span></span>dipdup<span class="w"> </span>run<span class="w"> </span><span class="o">[</span>OPTIONS<span class="o">]</span>
 </pre></div>
 </div>

src/dipdup/cli.py

@@ -204,7 +204,7 @@ class CLIContext:
 async def run(ctx: click.Context) -> None:
     """Run indexer.
 
-    Execution can be gracefully interrupted with `Ctrl+C` or `SIGTERM` signal.
+    Execution can be gracefully interrupted with `Ctrl+C` or `SIGINT` signal.
     """
     from dipdup.config import DipDupConfig
     from dipdup.dipdup import DipDup

src/dipdup/utils/sys.py

@@ -13,7 +13,6 @@
 IGNORE_SIGINT_CMDS = {*IGNORE_CONFIG_CMDS, None, 'schema', 'wipe'}
 
 _is_shutting_down = False
-_logger = logging.getLogger(__name__)
 
 
 async def _shutdown() -> None:  # pragma: no cover
@@ -22,7 +21,9 @@ async def _shutdown() -> None:  # pragma: no cover
         return
     _is_shutting_down = True
 
-    _logger.info('Shutting down')
+    # NOTE: Prevents BrokenPipeError when piping output to another process
+    sys.stderr.close()
+
     tasks = filter(lambda t: t != asyncio.current_task(), asyncio.all_tasks())
     list(map(asyncio.Task.cancel, tasks))
     await asyncio.gather(*tasks, return_exceptions=True)
@@ -63,5 +64,4 @@ def set_up_process(cmd: str | None) -> None:
 
     # NOTE: Format warnings as normal log messages
     logging.captureWarnings(True)
-    warnings.simplefilter('always', DeprecationWarning)
     warnings.formatwarning = lambda msg, *a, **kw: str(msg)