kopia lustrzana https://github.com/bugout-dev/moonstream
Merge pull request #1122 from moonstream-to/fix-subscription-log
Increase request timeout.pull/1123/head
commit
14fee1d85e
|
@ -36,6 +36,7 @@ from ..settings import (
|
||||||
MOONSTREAM_ENTITIES_RESERVED_TAGS,
|
MOONSTREAM_ENTITIES_RESERVED_TAGS,
|
||||||
THREAD_TIMEOUT_SECONDS,
|
THREAD_TIMEOUT_SECONDS,
|
||||||
MOONSTREAM_DB_V3_INDEX_INSTANCE,
|
MOONSTREAM_DB_V3_INDEX_INSTANCE,
|
||||||
|
BUGOUT_REQUEST_TIMEOUT_SECONDS,
|
||||||
)
|
)
|
||||||
from ..settings import bugout_client as bc
|
from ..settings import bugout_client as bc
|
||||||
from ..web3_provider import yield_web3_provider
|
from ..web3_provider import yield_web3_provider
|
||||||
|
@ -192,6 +193,7 @@ async def add_subscription_handler(
|
||||||
title=label,
|
title=label,
|
||||||
required_fields=required_fields,
|
required_fields=required_fields,
|
||||||
secondary_fields=content,
|
secondary_fields=content,
|
||||||
|
timeout=BUGOUT_REQUEST_TIMEOUT_SECONDS,
|
||||||
)
|
)
|
||||||
except EntityJournalNotFoundException as e:
|
except EntityJournalNotFoundException as e:
|
||||||
raise MoonstreamHTTPException(
|
raise MoonstreamHTTPException(
|
||||||
|
@ -200,7 +202,7 @@ async def add_subscription_handler(
|
||||||
internal_error=e,
|
internal_error=e,
|
||||||
)
|
)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Failed to get journal id")
|
logger.error(f"Failed to create subscription entity error: {str(e)}")
|
||||||
raise MoonstreamHTTPException(
|
raise MoonstreamHTTPException(
|
||||||
status_code=500,
|
status_code=500,
|
||||||
internal_error=e,
|
internal_error=e,
|
||||||
|
@ -585,6 +587,7 @@ async def update_subscriptions_handler(
|
||||||
),
|
),
|
||||||
required_fields=update_required_fields,
|
required_fields=update_required_fields,
|
||||||
secondary_fields=update_secondary_fields,
|
secondary_fields=update_secondary_fields,
|
||||||
|
timeout=BUGOUT_REQUEST_TIMEOUT_SECONDS,
|
||||||
)
|
)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Error update user subscriptions: {str(e)}")
|
logger.error(f"Error update user subscriptions: {str(e)}")
|
||||||
|
|
|
@ -17,7 +17,7 @@ bugout_client = Bugout(
|
||||||
brood_api_url=BUGOUT_BROOD_URL, spire_api_url=BUGOUT_SPIRE_EXTERNAL_URL
|
brood_api_url=BUGOUT_BROOD_URL, spire_api_url=BUGOUT_SPIRE_EXTERNAL_URL
|
||||||
)
|
)
|
||||||
|
|
||||||
BUGOUT_REQUEST_TIMEOUT_SECONDS = 5
|
BUGOUT_REQUEST_TIMEOUT_SECONDS = 10
|
||||||
|
|
||||||
HUMBUG_REPORTER_BACKEND_TOKEN = os.environ.get("HUMBUG_REPORTER_BACKEND_TOKEN")
|
HUMBUG_REPORTER_BACKEND_TOKEN = os.environ.get("HUMBUG_REPORTER_BACKEND_TOKEN")
|
||||||
|
|
||||||
|
|
|
@ -2,4 +2,4 @@
|
||||||
Moonstream library and API version.
|
Moonstream library and API version.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
MOONSTREAMAPI_VERSION = "0.4.7"
|
MOONSTREAMAPI_VERSION = "0.4.8"
|
||||||
|
|
Ładowanie…
Reference in New Issue