o 8s,z._lowercase_dictionary_keys..)r)rrrrr6src@seZdZUeed<dddZededBfddZededefdd Zde fd d Z d e dedBfd dZ de e fddZ de dedBfddZde dedBfddZdS)Configconfigr NcCs0|pi}t|||}tdi||_dS)Nr)_from_configuration_filesr_from_environment_variablesrr!)selfr!rrr__init__>s zConfig.__init__cCsZdtdBdtdBfdd}tjttjdtg}|D] }||}r*|SqdS)zLoad the first configuration file that its finds. Will first look in the PYICEBERG_HOME env variable, and then in the home directory. directoryNr cSsn|r5tj|t}tj|r5t|td }|}Wdn1s$wYt |j }t |}|SdS)N)encoding) ospathjoin PYICEBERG_YMLisfileopenrread strictyamlloaddatar)r&r)fyml_str file_configfile_config_lowercaserrr _load_yamlKs   z4Config._from_configuration_files.._load_yaml~) strrr(environgetr r) expandusergetcwd)r6 search_dirsr&r!rrrr"Cs  z Config._from_configuration_filescCsdtdttdtddfdd}tjD]+\}}|}|tr?|t td}|j dd d }d d |D}||||q|S) aRead the environment variables, to check if there are any prepended by PYICEBERG_. Args: config: Existing configuration that's being amended with configuration from environment variables. Returns: Amended configuration. _configr) config_valuer NcSst|dkr?|d}t|dkr|||<n!||vri||<t||tr*||}n tdd|d|t|dksdSdS)Nrz8Incompatible configurations, merging dict with a value: .z , value: )lenpoprr ValueErrorr*)r>r)r?elementrrr set_propertyls     z8Config._from_environment_variables..set_property__)maxsplitcSs g|] }|ddddqS)rFr@_r )replace)rpartrrr s z6Config._from_environment_variables..) rlistr8r(r9rr startswith PYICEBERGrAsplit)r!rEenv_varr? env_var_lowerkeypartsparts_normalizedrrrr#as  z"Config._from_environment_variablescCs0|jt}rt|tstd||StS)zReturn the default catalog name. Returns: The name of the default catalog in `default-catalog`. Returns `default` when the key cannot be found in the config file. z&Default catalog name should be a str: )r!r:DEFAULT_CATALOGrr8rCDEFAULT)r$default_catalog_namerrrget_default_catalog_names  zConfig.get_default_catalog_name catalog_namecCsft|jvr1|}|jt}t|tstd|||vr1||}t|ts/td|d|SdS)Nz.Catalog configurations needs to be an object: zConfiguration path catalogs.z needs to be an object)CATALOGr!rrrrC)r$rZcatalog_name_lowercatalogs catalog_confrrrget_catalog_configs    zConfig.get_catalog_configcCs,|jti}t|tstdt|S)Nz,Catalog configurations needs to be an object)r!r:r[rrrCrMkeys)r$r]rrrget_known_catalogss  zConfig.get_known_catalogsrSc CP|j|}dur&zt|WSty%}z t|d||d}~wwdS)Nz4 should be an integer or left unset. Current value: )r!r:intrCr$rSvalerrrrrget_int zConfig.get_intc Crb)Nz3 should be a boolean or left unset. Current value: )r!r:rrCrdrrrget_boolrhzConfig.get_bool)r N)__name__ __module__ __qualname__r__annotations__r% staticmethodr"r#r8rYr_rMrarcrgboolrirrrrr ;s  &  r )loggingr(r/pyiceberg.typedefrrrpyiceberg.typesrrOrWr[rVr r+ getLoggerrjloggerrrr rrrrs