o i@sfdZddlmZddlmZmZddlmZmZddlm Z eddGdd d Z Gd d d Z d S) z-In-process registry for queued platform jobs.) annotations) dataclassfield)datetimetimezone)AnyT)slotsc@sDeZdZUdZded<dZded<dZded<eed Z d ed <d S) JobDefinitionz*Metadata describing a queued platform job.strjob_namedefault queue_namerintretries)default_factorydict[str, Any]metadataN) __name__ __module__ __qualname____doc____annotations__r rrdictrrrplatform/jobs/job_registry.pyr s   r c@s8eZdZdZdddZddd Zdd dZdddZdS) JobRegistryzDTrack registered job types until a real queue backend is plugged in.returnNonecCs i|_dSN)_jobsselfrrr__init__s zJobRegistry.__init__jobr cCs||j|j<dSr)rr )r!r#rrrregisterszJobRegistry.registerr r JobDefinition | NonecCs |j|Sr)rget)r!r rrrr&s zJobRegistry.getrcCst|jttjdS)N)registered_jobs captured_at)listrrnowrutc isoformatr rrrsnapshot szJobRegistry.snapshotN)rr)r#r rr)r r rr%)rr)rrrrr"r$r&r-rrrrrs    rN) r __future__r dataclassesrrrrtypingrr rrrrrs