kopia lustrzana https://github.com/bugout-dev/moonstream
Black formating.
rodzic
2b995c8d95
commit
66d40335d6
|
@ -23,12 +23,15 @@ from ..settings import bugout_client as bc
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
router = APIRouter(prefix="/queries",)
|
router = APIRouter(
|
||||||
|
prefix="/queries",
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
@router.post("/{query_id}/update", tags=["queries"])
|
@router.post("/{query_id}/update", tags=["queries"])
|
||||||
async def update_query_data_handler(
|
async def update_query_data_handler(
|
||||||
request: Request, query_id: str = Query(...),
|
request: Request,
|
||||||
|
query_id: str = Query(...),
|
||||||
) -> Optional[Dict[str, Any]]:
|
) -> Optional[Dict[str, Any]]:
|
||||||
"""
|
"""
|
||||||
Request update data on S3 bucket
|
Request update data on S3 bucket
|
||||||
|
|
|
@ -30,7 +30,9 @@ from .subscriptions import BUGOUT_RESOURCE_TYPE_SUBSCRIPTION
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
router = APIRouter(prefix="/streams",)
|
router = APIRouter(
|
||||||
|
prefix="/streams",
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
def get_user_subscriptions(token: str) -> Dict[str, List[BugoutResource]]:
|
def get_user_subscriptions(token: str) -> Dict[str, List[BugoutResource]]:
|
||||||
|
@ -39,7 +41,9 @@ def get_user_subscriptions(token: str) -> Dict[str, List[BugoutResource]]:
|
||||||
"""
|
"""
|
||||||
response = bc.list_resources(
|
response = bc.list_resources(
|
||||||
token=token,
|
token=token,
|
||||||
params={"type": BUGOUT_RESOURCE_TYPE_SUBSCRIPTION,},
|
params={
|
||||||
|
"type": BUGOUT_RESOURCE_TYPE_SUBSCRIPTION,
|
||||||
|
},
|
||||||
timeout=BUGOUT_REQUEST_TIMEOUT_SECONDS,
|
timeout=BUGOUT_REQUEST_TIMEOUT_SECONDS,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -68,8 +68,8 @@ if MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX is None:
|
||||||
raise ValueError(
|
raise ValueError(
|
||||||
"MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX environment variable must be set"
|
"MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX environment variable must be set"
|
||||||
)
|
)
|
||||||
MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX = MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX.rstrip(
|
MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX = (
|
||||||
"/"
|
MOONSTREAM_S3_SMARTCONTRACTS_ABI_PREFIX.rstrip("/")
|
||||||
)
|
)
|
||||||
|
|
||||||
MOONSTREAM_CRAWLERS_SERVER_URL = os.environ.get("MOONSTREAM_CRAWLERS_SERVER_URL")
|
MOONSTREAM_CRAWLERS_SERVER_URL = os.environ.get("MOONSTREAM_CRAWLERS_SERVER_URL")
|
||||||
|
|
Ładowanie…
Reference in New Issue