G SrSSKrSSKrSSKrSSKJrJr SSKJr SSKJ r SSKJ r \R"\ R\ RS9rS\S \4S jrS\S \4S jrSS \S \S\\\4S\\\4S\\S\S \4Sjjrg)z?An adapter that takes a bq command and executes it with gcloud.N)DictOptional)bq_to_gcloud_config_classes) gcloud_runner)supported_gcloud_commands)global_flag_mappingscommand_mappings gcloud_outputreturncfURSS5RSS5RSS5RSS5RSS5RSS5RSS5RS S5RS S5RS S 5RS S5$)Nu┌+u┐u└u┘u├u┤u┬u┼u┴u│|─-)replace)r s 2platform/bq/gcloud_wrapper/bq_to_gcloud_adapter.py_swap_gcloud_box_to_bq_prettyrsE3'wucwucwucwucwucwucwucwucwucwuc c"[R"SSU5n[R"SSU5n[R"SSU5n[R"SSU5n[R"SSU5n[R"S S U5$) z1Converts gcloud table output to bq sparse output.u┌.*┐u└.*┘u │(.*)│z \1 u[├┤] u[│┼]rr)resub)r stripped_upper_borderstripped_lower_bordermostly_stripped_side_bordersstripped_side_bordersno_vertical_barss r_swap_gcloud_box_to_bq_sparser%s~&&b-@&&b2GH!#W3"&&d4PQVVK/DE - ..rresource bq_commandbq_global_flagsbq_command_flags identifierdry_runc8[RUUUUUS9nU(a3[SRS/[R "U5-55 g[ R"U[RS9nURSS5n[RXS9n UR(d UR$S n [URRS 5Hn S n [!U 5R#5n U R%U 5nU(aU n OdU R&(d"U R)XURS 55n O1S U;aX- n O&US :Xa [+U 5n OUS:Xa [-U 5n OU n U (dM[U 5 M U (a[.R0"U 5n[3U[45(a-/nUH$nUR7U R9UU55 M& OU R9X5nS U:Xa*[[.R:"US S95 UR$SU:Xa[[.R:"USSS95 UR$UR$![.R<a [U 5 UR$f=f)adTakes a bq command and executes it with gcloud returning the exit code. Args: resource: The resource the command is being run on, named to align with `gcloud` commands. For example, 'jobs' or 'datasets'. bq_command: The bq command to run. For example, 'ls' or 'show'. bq_global_flags: The BQ CLI global flags to use when running the command. bq_command_flags: The BQ CLI command flags to use when running the command. identifier: The identifier of the resource to act on. dry_run: If true, the gcloud command will be printed instead of executed. Returns: The exit code of the gcloud command. )r r!r"r#r$rgcloudr)stderrformatsparse)r r!r project_idjsonpretty),:) separators prettyjsonT)indent sort_keys)GCLOUD_COMMAND_GENERATORget_gcloud_commandprintjoinrquote_flag_valuesrrun_gcloud_command subprocessSTDOUTgetget_command_mappingstdout returncodeiterreadlinestrstrip$synchronous_progress_message_matcherprint_resourcestatus_mappingrrr,loads isinstancelistappend json_mappingdumpsJSONDecodeError)r r!r"r#r$r%gcloud_commandproc bq_formatcommand_mapping json_outputraw_line line_to_printoutputis_progress_message parsed_json json_object item_dicts rrun_bq_command_using_gcloudr[1sl,,>>%' ?.    J);;NK L   ) )    $ !!(H5),@@A/  ??+t{{++R0hM ] "F)NNm  + +%44 o11,?m 9 k h 3F;m h 3F;mm} M/10JJ{+k K & & $I   _99)YO P%&22;J 9  djj<=  9 $ djjQ$?@     K  sB I,/%I,,JJ)NF)__doc__r,rr;typingrrgcloud_wrapperrrrGcloudCommandGeneratorSUPPORTED_GLOBAL_FLAGSSUPPORTED_COMMANDSr5rCrrboolintr[rrresE !6(46MM2II.AA $ / / /"!% ]]]#s(^]38n ]  ]  ] ]r