o Ki @sfddlZddlZddlmZedeGdddejdZGdddeZ Gd d d Z dS) N)Optional ubuntuproc @s4eZdZejdededeedeefddZdS)AbstractProgress total_steps done_stepsprevious_step_messagecurrent_step_messagecCdSNselfrrrrr r 7/usr/lib/python3/dist-packages/uaclient/api/__init__.pyprogress s zAbstractProgress.progressN) __name__ __module__ __qualname__abcabstractmethodintrstrrr r r rr sr) metaclassc @s.eZdZdededeedeefddZdS) NullProgressrrrrcCr r r r r r rrszNullProgress.progressN)rrrrrrrr r r rrsrc@sTeZdZddeefddZdefddZdd Zdd efd d Z d e fddZ dS)ProgressWrapperNprogress_objectcCs.|dur||_nt|_d|_d|_d|_dS)Nr)rrrrr)r rr r r__init__#s  zProgressWrapper.__init__messagecCs2|jj|j|j|j|d||_|jd7_dS)Nrrrr)rrrrr)r rr r rr,szProgressWrapper.progresscCs&|j|_|jj|j|j|jdddS)Nr)rrrrrr r r rfinish6s zProgressWrapper.finisheventcCs"t|jdr|j||dSdS)z This is our secret event system. We use it internally to insert prompts and extra messages in the middle of operations at certain points. We don't consider this stable enough to expose to the public API. _on_eventN)hasattrrr#)r r"payloadr r remit?s zProgressWrapper.emitreturncCst|jdr |jjSdS)Nis_interactiveF)r$rr(r r r rr(Hs zProgressWrapper.is_interactiver ) rrrrrrrrr!r&boolr(r r r rr"s     r) rloggingtypingr getLogger addHandler NullHandlerABCMetarrrr r r rs