@@ -64,15 +64,15 @@ def __init__(self):
64
64
self ._yaml = self ._load_config (config_path )
65
65
66
66
# Define the configuration variables to be parsed from the YAML file
67
- self .flowkit_python_api_key = self ._yaml .get ("FLOWKIT_PYTHON_API_KEY" )
68
- self .flowkit_python_endpoint = self ._yaml .get ("FLOWKIT_PYTHON_ENDPOINT" , "http://localhost:50052" )
69
- self .flowkit_python_workers = self ._yaml .get ("FLOWKIT_PYTHON_WORKERS" , 4 )
70
- self .use_ssl = self ._yaml .get ("USE_SSL" , False )
71
- self .ssl_cert_public_key_file = self ._yaml .get ("SSL_CERT_PUBLIC_KEY_FILE" )
72
- self .ssl_cert_private_key_file = self ._yaml .get ("SSL_CERT_PRIVATE_KEY_FILE" )
73
- self .extract_config_from_azure_key_vault = self ._yaml .get ("EXTRACT_CONFIG_FROM_AZURE_KEY_VAULT" , False )
74
- self .azure_managed_identity_id = self ._yaml .get ("AZURE_MANAGED_IDENTITY_ID" )
75
- self .azure_key_vault_name = self ._yaml .get ("AZURE_KEY_VAULT_NAME" )
67
+ self .flowkit_python_api_key = str ( self ._yaml .get ("FLOWKIT_PYTHON_API_KEY" , "" ) )
68
+ self .flowkit_python_endpoint = str ( self ._yaml .get ("FLOWKIT_PYTHON_ENDPOINT" , "http://localhost:50052" ) )
69
+ self .flowkit_python_workers = int ( self ._yaml .get ("FLOWKIT_PYTHON_WORKERS" , 4 ) )
70
+ self .use_ssl = bool ( self ._yaml .get ("USE_SSL" , False ) )
71
+ self .ssl_cert_public_key_file = str ( self ._yaml .get ("SSL_CERT_PUBLIC_KEY_FILE" , "" ) )
72
+ self .ssl_cert_private_key_file = str ( self ._yaml .get ("SSL_CERT_PRIVATE_KEY_FILE" , "" ) )
73
+ self .extract_config_from_azure_key_vault = bool ( self ._yaml .get ("EXTRACT_CONFIG_FROM_AZURE_KEY_VAULT" , False ) )
74
+ self .azure_managed_identity_id = str ( self ._yaml .get ("AZURE_MANAGED_IDENTITY_ID" , "" ) )
75
+ self .azure_key_vault_name = str ( self ._yaml .get ("AZURE_KEY_VAULT_NAME" , "" ) )
76
76
77
77
# If azure key vault configured, read values from vault
78
78
if self .extract_config_from_azure_key_vault :
0 commit comments