lSrSSKJr SSKJr SSKJr SSKr\"S/5rSSS .rS r S r S r S r g)aCode to clean-up transform the JSON description of a dataflow. Example clean-ups: 1. Dictionaries representing primitives with a schema will be converted to the primitive: Ex: { '@type': "https://schema.org/Text", 'value': "Hello" } becomes "Hello" 2. Fields that are unlikely to be human consumable may be hidden. Ex: The serialized_fn field will be hidden, since humans are unlikely to try to read the serialized Java object. )absolute_import)division)unicode_literalsN serialized_fncUR$N) boolean_valuevalues 0lib/googlecloudsdk/api_lib/dataflow/step_json.pyr #s u/B/BcUR$r) string_valuer s r r r $s E,>,>r)zhttp://schema.org/Booleanzhttp://schema.org/Textc0nUR(aTURRH:nUR[;dM[ UR 5XR'M< UR URUS.$)zConverts a Step message into a dict with more sensible structure. Args: step_msg: A Step message. Returns: A dict with the cleaned up information. )kindname properties)radditionalPropertieskey_EXCLUDED_PROPERTIES _ExtractValuer rr)step_msgrprops r _ExtractStepr(sg* ##88 - -,TZZ8 889 mmmm rc0nURRHnURXR'M UR SS5nU=(a [ R UR S5nU(aU(d&[S[R"U555$U"US5$![a SRUR U5s$f=f)zExtracts an object from the proto representation of the JSON object. Args: proto: A protocol representation of a JSON object. Returns: A clean representation of the JSON object. If it was an object representing a primitive, then that primitive. z@typeNc3@# UHupU[U54v M g7fr)r).0kvs r *_ExtractDecoratedObject..RsK2J$!M!$%2Jsr z+Missing value for type [{0}] in proto [{1}]) object_valuerr rget_VALUE_RETRIEVERSrdictsix iteritemsKeyErrorformat)proto prop_dictrty retrievers r _ExtractDecoratedObjectr/=s)  ++d**Ihh,}}Wd#"A&**2??DA) 9 K#-- 2JK KK  Yw' ((  8 ? ?    s( B33&CCc"UR(a [U5$UR(a0URRVs/sHn[ U5PM sn$UR (a UR $SR U5$s snf)NzNo decoding provided for: {0})r#r/ array_valueentriesrrr*)r+r s r rr^su  "5 )) &+&7&7&?&? @&?M! &? @@     ( / / 66 AsB cXURVs/sHn[U5PM sn$s snf)zExtract the cleaned up step dictionary for all the steps in the job. Args: job: A Job message. Returns: A list of cleaned up step dictionaries. )stepsr)jobsteps r ExtractStepsr7ls%*- 3,t  33 3s') __doc__ __future__rrrr'setrr%rr/rr7rr r<sL '' O,-"C> * B 74r