small fixes
This commit is contained in:
parent
26d2ddae54
commit
39d28d2e8d
@ -5,7 +5,7 @@ from dataclasses import dataclass
|
||||
from typing import Any, Dict, List, Optional, Tuple
|
||||
import pandas as pd
|
||||
from utils.logging import HasLogger
|
||||
from datetime import date, timedelta, datetime
|
||||
from datetime import date, timedelta, datetime, timezone
|
||||
from pathlib import Path
|
||||
import requests
|
||||
from urllib.parse import quote
|
||||
|
||||
8
app.py
8
app.py
@ -2,7 +2,6 @@ import logging
|
||||
from apscheduler.schedulers.blocking import BlockingScheduler
|
||||
|
||||
import EnergyPriceScraperFactory
|
||||
import app_impl
|
||||
|
||||
from utils.logging import setup_logging
|
||||
from utils.time import WARSAW_TZ
|
||||
@ -10,7 +9,8 @@ from utils.time import WARSAW_TZ
|
||||
from app_impl import hourly_tick
|
||||
from utils.logging import function_logger
|
||||
|
||||
import datetime
|
||||
# import datetime
|
||||
# import app_impl
|
||||
|
||||
setup_logging(logging.DEBUG)
|
||||
sched = BlockingScheduler(timezone=WARSAW_TZ)
|
||||
@ -20,9 +20,9 @@ def run(name: str):
|
||||
log.info(f"Running {name}")
|
||||
try:
|
||||
conn = EnergyPriceScraperFactory.setup_db()
|
||||
pstryk_scraper = EnergyPriceScraperFactory.create(name, conn=conn)
|
||||
scraper = EnergyPriceScraperFactory.create(name, conn=conn)
|
||||
# 11:30 and hourly safety check
|
||||
hourly_tick(pstryk_scraper)
|
||||
hourly_tick(scraper)
|
||||
except Exception as e:
|
||||
log.error(f"{name} throw an exception: {e}")
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user