network.bsky.jetstream.get_import_status¶

class atproto_client.models.network.bsky.jetstream.get_import_status.Params¶

Bases: ParamsModelBase

Parameters model for network.bsky.jetstream.getImportStatus.

field job: str | None = None¶

class atproto_client.models.network.bsky.jetstream.get_import_status.ParamsDict¶

Bases: TypedDict

job: NotRequired[str | None]¶: Job id returned by importTimestamps. When omitted, the current or most recent job is reported.

class atproto_client.models.network.bsky.jetstream.get_import_status.Response¶

Bases: ResponseModelBase

Output data model for network.bsky.jetstream.getImportStatus.

field bucketed: bool | None = None¶: Whether Phase A+B completed (the offset files are durable).

field error: str | None = None¶: Failure detail; present only when state is failed.

field finished_at: str | None = None¶: Present only for a terminal job.

field job: str [Required]¶: Job id.

field phase: Literal['parse_bucket', 'apply'] | str | None = None¶

field rows_corrupt_offset: int | None = None¶

Rows corrupt offset.

Constraints:

ge = 0

field rows_matched_all_versions: int | None = None¶

Rows matched all versions.

Constraints:

ge = 0

field rows_matched_specific: int | None = None¶

Rows matched specific.

Constraints:

ge = 0

field rows_mutated: int | None = None¶

Rows mutated.

Constraints:

ge = 0

field rows_rejected: int | None = None¶

Rows rejected.

Constraints:

ge = 0

field rows_total: int | None = None¶

Rows total.

Constraints:

ge = 0

field rows_valid: int | None = None¶

Rows valid.

Constraints:

ge = 0

field segments_applied: int | None = None¶

Segments processed so far in Phase C.

Constraints:

ge = 0

field segments_examined: int | None = None¶

Segments examined.

Constraints:

ge = 0

field segments_patched: int | None = None¶

Segments patched.

Constraints:

ge = 0

field segments_to_apply: int | None = None¶

Constraints:

ge = 0

field specific_cids_unmatched: int | None = None¶

Specific cids unmatched.

Constraints:

ge = 0

field state: Literal['running', 'complete', 'failed'] | str [Required]¶: Lifecycle state.

field submitted_at: str | None = None¶: Submitted at.