CollectorRunSummary

Documentation for eth_defi.feed.collector.CollectorRunSummary Python class.

class CollectorRunSummary

Bases: object

Summary counters for one collector run.

Attributes summary

sources_loaded	Number of configured sources seen at the start of the run.
sources_succeeded	Number of sources collected successfully.
sources_failed	Number of sources that failed or were skipped with an error.
feeders_skipped	Number of feeder YAML files where all sources were disabled.
posts_fetched	Total number of parsed posts returned by all successful source reads.
posts_inserted	Number of newly inserted posts after deduplication.
source_results	Per-source collection results for dashboard rendering.
twitter_method	Twitter collection method used: "list", "rss-bridge", or None if no Twitter sources.
rss_duration_seconds	Duration of the RSS phase in seconds.
linkedin_duration_seconds	Duration of the LinkedIn phase in seconds.
twitter_duration_seconds	Duration of the Twitter phase in seconds.
total_duration_seconds	Total scan duration in seconds.
stablecoin_rate_status	Stablecoin rate side-job status: disabled, skipped_recent, succeeded, or failed.
stablecoin_rate_summary	Stablecoin rate side-job summary when a refresh ran successfully.
stablecoin_rate_error	Stablecoin rate side-job error when an unexpected refresh exception was caught.

Methods summary

__init__([sources_loaded, ...])

sources_loaded: int

Number of configured sources seen at the start of the run.

sources_succeeded: int

Number of sources collected successfully.

sources_failed: int

Number of sources that failed or were skipped with an error.

feeders_skipped: int

Number of feeder YAML files where all sources were disabled.

posts_fetched: int

Total number of parsed posts returned by all successful source reads.

posts_inserted: int

Number of newly inserted posts after deduplication.

source_results: Optional[list[eth_defi.feed.collector.CollectedSourceResult]]

Per-source collection results for dashboard rendering.

twitter_method: Optional[str]

Twitter collection method used: “list”, “rss-bridge”, or None if no Twitter sources.

rss_duration_seconds: Optional[float]

Duration of the RSS phase in seconds.

linkedin_duration_seconds: Optional[float]

Duration of the LinkedIn phase in seconds.

twitter_duration_seconds: Optional[float]

Duration of the Twitter phase in seconds.

total_duration_seconds: Optional[float]

Total scan duration in seconds.

stablecoin_rate_status: Optional[str]

Stablecoin rate side-job status: disabled, skipped_recent, succeeded, or failed.

stablecoin_rate_summary: Optional[Any]

Stablecoin rate side-job summary when a refresh ran successfully.

stablecoin_rate_error: Optional[str]

Stablecoin rate side-job error when an unexpected refresh exception was caught.

__init__(sources_loaded=0, sources_succeeded=0, sources_failed=0, feeders_skipped=0, posts_fetched=0, posts_inserted=0, source_results=None, twitter_method=None, rss_duration_seconds=None, linkedin_duration_seconds=None, twitter_duration_seconds=None, total_duration_seconds=None, stablecoin_rate_status=None, stablecoin_rate_summary=None, stablecoin_rate_error=None)

Parameters

• sources_loaded (int) –

• sources_succeeded (int) –

• sources_failed (int) –

• feeders_skipped (int) –

• posts_fetched (int) –

• posts_inserted (int) –

• source_results (Optional[list[eth_defi.feed.collector.CollectedSourceResult]]) –

• twitter_method (Optional[str]) –

• rss_duration_seconds (Optional[float]) –

• linkedin_duration_seconds (Optional[float]) –

• twitter_duration_seconds (Optional[float]) –

• total_duration_seconds (Optional[float]) –

• stablecoin_rate_status (Optional[str]) –

• stablecoin_rate_summary (Optional[Any]) –

• stablecoin_rate_error (Optional[str]) –

Return type

None