diff --git a/backend/moonstream/providers/bugout.py b/backend/moonstream/providers/bugout.py index ee96698d..1ace3ce9 100644 --- a/backend/moonstream/providers/bugout.py +++ b/backend/moonstream/providers/bugout.py @@ -16,6 +16,7 @@ from sqlalchemy.orm import Session from .. import data from ..stream_queries import StreamQuery +from ..settings import ETHTXPOOL_HUMBUG_CLIENT_ID logger = logging.getLogger(__name__) logger.setLevel(logging.WARN) @@ -376,7 +377,7 @@ ethereum_txpool_provider = EthereumTXPoolProvider( description=ethereum_txpool_description, default_time_interval_seconds=5, estimated_events_per_time_interval=50, - tags=["client:ethereum-txpool-crawler-0"], + tags=[f"client:{ETHTXPOOL_HUMBUG_CLIENT_ID}"], ) nft_summary_description = """Event provider for NFT market summaries. diff --git a/backend/moonstream/settings.py b/backend/moonstream/settings.py index 0a90d751..d18bb852 100644 --- a/backend/moonstream/settings.py +++ b/backend/moonstream/settings.py @@ -46,6 +46,10 @@ for path in MOONSTREAM_OPENAPI_LIST: DEFAULT_STREAM_TIMEINTERVAL = 5 * 60 +ETHTXPOOL_HUMBUG_CLIENT_ID = os.environ.get( + "ETHTXPOOL_HUMBUG_CLIENT_ID", "client:ethereum-txpool-crawler-0" +) + # S3 Bucket ETHERSCAN_SMARTCONTRACTS_BUCKET = os.environ.get("AWS_S3_SMARTCONTRACT_BUCKET") if ETHERSCAN_SMARTCONTRACTS_BUCKET is None: diff --git a/backend/sample.env b/backend/sample.env index 779bbb0c..6c44a369 100644 --- a/backend/sample.env +++ b/backend/sample.env @@ -9,3 +9,4 @@ export AWS_S3_SMARTCONTRACT_BUCKET="" export BUGOUT_BROOD_URL="https://auth.bugout.dev" export BUGOUT_SPIRE_URL="https://spire.bugout.dev" export HUMBUG_REPORTER_BACKEND_TOKEN="" +export ETHTXPOOL_HUMBUG_CLIENT_ID="" \ No newline at end of file