Add lint fixes.

pull/550/head
Andrey Dolgolev 2022-02-16 18:23:29 +02:00
rodzic 025baeb1c4
commit 4dd101eb43
4 zmienionych plików z 12 dodań i 6 usunięć

Wyświetl plik

@ -21,7 +21,9 @@ from ..settings import bugout_client as bc
logger = logging.getLogger(__name__)
router = APIRouter(prefix="/queries",)
router = APIRouter(
prefix="/queries",
)
@router.post("/{query_id}/update", tags=["queries"])

Wyświetl plik

@ -81,14 +81,17 @@ async def now_handler() -> data.NowResponse:
@app.post("/jobs/stats_update", tags=["jobs"])
async def status_handler(
stats_update: data.StatsUpdateRequest, background_tasks: BackgroundTasks,
stats_update: data.StatsUpdateRequest,
background_tasks: BackgroundTasks,
):
"""
Update dashboard endpoint create are tasks for update.
"""
dashboard_resource: BugoutResource = bc.get_resource(
token=stats_update.token, resource_id=stats_update.dashboard_id, timeout=10,
token=stats_update.token,
resource_id=stats_update.dashboard_id,
timeout=10,
)
# get all user subscriptions
@ -168,7 +171,9 @@ async def status_handler(
@app.post("/jobs/{query_id}/query_update", tags=["jobs"])
async def queries_data_update_handler(
query_id: str, request: data.QueryDataUpdate, background_tasks: BackgroundTasks,
query_id: str,
request: data.QueryDataUpdate,
background_tasks: BackgroundTasks,
) -> Dict[str, Any]:
s3_client = boto3.client("s3")

Wyświetl plik

@ -89,4 +89,3 @@ if MOONSTREAM_MOONWORM_TASKS_JOURNAL == "":
MOONSTREAM_QUERIES_BUCKET = os.environ.get("MOONSTREAM_QUERIES_BUCKET", "")
if MOONSTREAM_QUERIES_BUCKET == "":
raise ValueError("MOONSTREAM_QUERIES_BUCKET environment variable must be set")

Wyświetl plik

@ -5,7 +5,7 @@ from io import StringIO
import csv
import boto3
import boto3 # type: ignore
from moonstreamdb.db import yield_db_session_ctx