primus.cli.shared.task_output_storage module

primus.cli.shared.task_output_storage.compact_task_output_for_storage(output_payload: Any, *, output_attachment_path: str, output_attachment_metadata: Mapping[str, Any] | None = None, status: str = 'ok', error_message: str | None = None) → str

primus.cli.shared.task_output_storage.download_task_output_artifact(*, task_id: str, compact_output: Any, client: Any = None, artifact_store: GraphQLArtifactStore | None = None) → bytes

Read a compacted task output through its GraphQL-authorized ticket.

primus.cli.shared.task_output_storage.persist_task_output_artifact(*, task_id: str, output_payload: Any, format_type: str, existing_attached_files: List[str] | None = None, status: str = 'ok', error_message: str | None = None, client: Any = None, artifact_store: GraphQLArtifactStore | None = None) → Tuple[str, List[str], str]

Persist full task output as a GraphQL-authorized attachment and compact envelope.

primus.cli.shared.task_output_storage.upload_task_attachment_bytes(*, task_id: str, filename: str, body: bytes, content_type: str, client: Any = None, artifact_store: GraphQLArtifactStore | None = None) → Dict[str, Any]

Upload a task attachment through an application-authorized HTTPS ticket.