From ec2f6c6b800f04347915d0fc8a2d440cc97dd28e Mon Sep 17 00:00:00 2001 From: Lex Berezhny Date: Tue, 29 Sep 2020 07:52:28 -0400 Subject: [PATCH] lint --- lbry/wallet/database.py | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/lbry/wallet/database.py b/lbry/wallet/database.py index 07bb66a1f..fda8ace77 100644 --- a/lbry/wallet/database.py +++ b/lbry/wallet/database.py @@ -7,7 +7,6 @@ from binascii import hexlify from collections import defaultdict from dataclasses import dataclass from contextvars import ContextVar -from concurrent.futures.thread import ThreadPoolExecutor from typing import Tuple, List, Union, Callable, Any, Awaitable, Iterable, Dict, Optional from datetime import date from prometheus_client import Gauge, Counter, Histogram @@ -18,6 +17,12 @@ from .transaction import Transaction, Output, OutputScript, TXRefImmutable, Inpu from .constants import TXO_TYPES, CLAIM_TYPES from .util import date_to_julian_day +from concurrent.futures.thread import ThreadPoolExecutor # pylint: disable=wrong-import-order +if platform.system() == 'Windows' or 'ANDROID_ARGUMENT' or 'KIVY_BUILD' in os.environ: + from concurrent.futures.thread import ThreadPoolExecutor as ReaderExecutorClass # pylint: disable=reimported +else: + from concurrent.futures.process import ProcessPoolExecutor as ReaderExecutorClass + log = logging.getLogger(__name__) sqlite3.enable_callback_tracebacks(True) @@ -61,13 +66,6 @@ def run_read_only_fetchone(sql, params): raise -if platform.system() == 'Windows' or 'ANDROID_ARGUMENT' or 'KIVY_BUILD' in os.environ: - ReaderExecutorClass = ThreadPoolExecutor -else: - from concurrent.futures.process import ProcessPoolExecutor - ReaderExecutorClass = ProcessPoolExecutor - - class AIOSQLite: reader_executor: ReaderExecutorClass