i=ddlZddlmZddlmZmZmZmZddlm Z m Z ddl m Z ddl mZddlmZddlmZmZmZmZmZdd lmZdd lmZdd lmZdd lmZdd lm Z ddl!m"Z"dZ#dZ$de%dee%effdZ&edGdde Z'y)N) dataclass)AnyDictOptionalTuple) CredentialsHasCredentials)load_yaml_text) ProfileConfig)MissingProfileTarget)CompilationErrorDbtProfileErrorDbtProjectErrorDbtRuntimeErrorProfileConfigError) get_flags)load_file_contents)ValidationError) fire_event)DbtValidationError)ProfileRendererzW dbt encountered an error while trying to read your profiles.yml file. {error_string} profiles_dirreturncrtjj|d}d}tjj|rB t |d}t |}|s%d|d}t tj||SiS#t$r'}tj|}t||d}~wwxYw)N profiles.ymlF)stripzThe profiles.yml file at z is empty error_string) ospathjoinisfilerr rINVALID_PROFILE_MESSAGEformatr)rr!contents yaml_contentmsges S/var/www/html/strategist-ai/venv/lib/python3.12/site-packages/dbt/config/profile.py read_profiler+!s 77<< n 5DH ww~~d 1)$e)& & " K ( ( serialize_credentialsc|j|j|j|jd}|r|jj d|d<|S)amUnlike to_project_config, this dict is not a mirror of any existing on-disk data structure. It's used when creating a new profile from an existing one. :param serialize_credentials bool: If True, serialize the credentials. Otherwise, the Credentials object will be copied. :returns dict: The serialized profile. r/r0r1r2T omit_noner2)r/r0r1r2to_dict)r7r:results r*to_profile_infozProfile.to_profile_infoUsU!--++||++   !$($4$4$<$)>)@@@r9c |jr7|jjd}|jj||jd}t j|y#t $r}t ||d}~wwxYw)NTr=)r:)r2r?validaterAr rr)r7dctexcs r*rSzProfile.validatezs{ 3&&...>  ))#.&&T&BC  " "3 ' 3$S)s 2 3sA*A-- B6 BBprofilecddlm}d|vrtdj|||j d} ||}|j |}|j ||j|}|S#ttf$rI}t|tr t|n |j} tdj||| |d}~wwxYw)Nr) load_pluginrDz;required field "type" not found in profile {} and target {}z4Credentials in profile "{}", target "{}" invalid: {}) dbt.adapters.factoryrXrr%poptranslate_aliasesrS from_dictrrrNstrmessage) rVr/r0rXtypenameclsdatar2r)r(s r*_credentials_from_profilez!Profile._credentials_from_profiles 5  !MTT +  ;;v& h'C((1D LL ---K 1 &q/:#a& C!FMM +s   s;A55C ACC args_profile_nameproject_profile_namec`d}|}||}|"dj|}t||S)Ncddlm}|jdz jr|jS|j dz S)NrPathrz.dbt)pathlibrhcwdexistshomergs r*default_profiles_dirz7Profile.pick_profile_name..default_profiles_dirs8 $"&((*~"=!E!E!G488: aTYY[[aMa ar9a[dbt cannot run because no profile was specified for this dbt project. To specify a profile for this project, add a line like the this to your dbt_project.yml file: profile: [profile name] Here, [profile name] should be replaced with a profile name defined in your profiles.yml file. You can find profiles.yml here: {profiles_file}/profiles.yml ) profiles_file)r%r)rcrdrmr/NO_SUPPLIED_PROFILE_ERRORs r*pick_profile_namezProfile.pick_profile_namesU b ,  (,L   ) F24  &"";< <r9cd|vrtdj||d}||vr8djd|D}dj|||}t|d||}t|tsd|d |d }t|d|S) Noutputsz%outputs not specified in profile '{}' c3>K|]}dj|yw)z - {}N)r%).0outputs r* z,Profile._get_profile_data..sM6v 6MszcThe profile '{}' does not have a target named '{}'. The valid target names for this profile are: {}invalid_target) result_typezoutput 'z' of profile 'z"' is misconfigured in profiles.yml)rr%r"rNrF)rVr/r0rrr( profile_datas r*_get_profile_datazProfile._get_profile_datas G #!"I"P"PQ]"^_ _)$ g %iiMWMMG??Ev +w@  "#3CD D{+ ,-;-~l^D01 "#3CD Dr9c>|||||}|j|S)aCreate a profile from an existing set of Credentials and the remaining information. :param credentials: The credentials dict for this profile. :param threads: The number of threads to use for connections. :param profile_name: The profile name used for this profile. :param target_name: The target name used for this profile. :raises DbtProfileError: If the profile is invalid. :returns: The new Profile object. r<)rS)r`r2r1r/r0rVs r*from_credentialszProfile.from_credentialss-&%##   r9 raw_profiletarget_overriderendererc ||}n1d|vr|j|d}nd}tt|||j|||} |j |}||fS#t $r}t t||d}~wwxYw)zYThis is a containment zone for the hateful way we're rendering profiles. NrIdefault)r/r0) render_valuerr r{ render_datar rr]) r`r~r/rrr0raw_profile_datarzrUs r*render_profilezProfile.render_profiles$  &)K  $"// H0EFK#K +S^_ `00lKX 5#//0@ALL((  5!#c(+ 4 5s A B)A>>Bthreads_overridec|j||||\}}|jdt}||}|j|||} |j | |||S)aCreate a profile from its raw profile information. (this is an intermediate step, mostly useful for unit testing) :param raw_profile: The profile data for a single profile, from disk as yaml and its values rendered with jinja. :param profile_name: The profile name used. :param renderer: The config renderer. :param target_override: The target to use, if provided on the command line. :param threads_override: The thread count to use, if provided on the command line. :raises DbtProfileError: If the profile is invalid or missing, or the target could not be found :returns: The new Profile object. r1)r2r/r0r1)rrZDEFAULT_THREADSrbr}) r`r~r/rrrr0rzr1r2s r*from_raw_profile_infozProfile.from_raw_profile_info"s~4%($6$6 % ! \ ""9o>  '&G#&#@#@ , $ ###%# $  r9 raw_profilesc||vrtdj|||}|s%d|d}ttj||j |||||S)a :param raw_profiles: The profile data, from disk as yaml. :param profile_name: The profile name to use. :param renderer: The config renderer. :param target_override: The target to use, if provided on the command line. :param threads_override: The thread count to use, if provided on the command line. :raises DbtProjectError: If there is no profile name specified in the project or the command line arguments :raises DbtProfileError: If the profile is invalid or missing, or the target could not be found :returns: The new Profile object. z!Could not find profile named '{}'zProfile z in profiles.yml is emptyr)r~r/rrr)rr%rr$r)r`rr/rrrr~r(s r*from_raw_profileszProfile.from_raw_profilesQs. | +!"E"L"L\"Z[ [#<0 \N*CDC!"9"@"@c"@"RS S((#%+- )  r9profile_name_overridect}t|j}|j||}|j |||||S)aGiven the raw profiles as read from disk and the name of the desired profile if specified, return the profile component of the runtime config. :param args argparse.Namespace: The arguments as parsed from the cli. :param project_profile_name Optional[str]: The profile name, if specified in a project. :raises DbtProjectError: If there is no profile name specified in the project or the command line arguments, or if the specified profile is not found :raises DbtProfileError: If the profile is invalid or missing, or the target could not be found. :returns Profile: The new Profile object. )rr/rrr)rr+ PROFILES_DIRrpr) r`rrdrrrflagsrr/s r*renderzProfile.renderzsV. #E$6$67 ,,-BDXY $$%%+- %  r9)FrM)NN)NNN)__name__ __module__ __qualname__r]__annotations__intrrrboolr8rArJobjectrQrS staticmethodrbrrpr{ classmethodr}rrrrrrr9r*r.r.7sG L38n$     !    *Td3PS8n& S#X AFAtA 3c3h/2AD >/3 #C= &sm    Dc3h/2AD c3h6      6 )#s(^ ) )"# ) " ) sDcN" # ) )D *.*. , #s(^, , " , "# , #3- ,  , , \ *.*. & 38n& & " & "# & #3- &  & & P 04)-*.  ! 'sm  (}  "#  #3-     r9r.)(r dataclassesrtypingrrrr!dbt.adapters.contracts.connectionrr dbt.clients.yaml_helperr dbt.contracts.projectr dbt.events.typesr dbt.exceptionsr rrrr dbt.flagsrdbt_common.clients.systemrdbt_common.dataclass_schemardbt_common.events.functionsrdbt_common.exceptionsrrrrr$r]r+r.rr9r*rs !--I2/1 8724%stCH~, b nb b r9