CollectedSourceResult

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

class CollectedSourceResult

Bases: object

Detailed collection result for one tracked source.

Attributes summary

feeder_id

Canonical feeder slug for the collected source.

name

Human-readable feeder name for diagnostics.

role

Feeder role such as protocol, curator, or vault.

source_type

Source transport type such as rss, twitter, or linkedin.

status

Final status for this source, such as success or failed.

posts_fetched

Number of parsed posts fetched from this source.

posts_inserted

Number of inserted posts after deduplication.

last_post_published_at

Last published timestamp seen in this source, if any.

error

Error message when the source failed or was skipped.

auth_blocked

True when all bridge attempts failed and at least one returned HTTP 503 (LinkedIn auth barrier).

Methods summary

__init__(feeder_id, name, role, source_type, ...)

feeder_id: str

Canonical feeder slug for the collected source.

name: str

Human-readable feeder name for diagnostics.

role: str

Feeder role such as protocol, curator, or vault.

source_type: str

Source transport type such as rss, twitter, or linkedin.

status: str

Final status for this source, such as success or failed.

posts_fetched: int

Number of parsed posts fetched from this source.

posts_inserted: int

Number of inserted posts after deduplication.

last_post_published_at: Optional[datetime.datetime]

Last published timestamp seen in this source, if any.

error: Optional[str]

Error message when the source failed or was skipped.

auth_blocked: bool

True when all bridge attempts failed and at least one returned HTTP 503 (LinkedIn auth barrier).

__init__(feeder_id, name, role, source_type, status, posts_fetched=0, posts_inserted=0, last_post_published_at=None, error=None, auth_blocked=False)
Parameters
Return type

None