airflow.providers.databricks.utils.databricks
¶
Module Contents¶
Functions¶
|
Normalize content or all values of content if it is a dict to a string. The |
|
Validates correctness of the event |
- airflow.providers.databricks.utils.databricks.normalise_json_content(content, json_path='json')[source]¶
Normalize content or all values of content if it is a dict to a string. The function will throw if content contains non-string or non-numeric non-boolean types. The reason why we have this function is because the
self.json
field must be a dict with only string values. This is becauserender_template
will fail for numerical values.The only one exception is when we have boolean values, they can not be converted to string type because databricks does not understand ‘True’ or ‘False’ values.
- airflow.providers.databricks.utils.databricks.validate_trigger_event(event)[source]¶
Validates correctness of the event received from
DatabricksExecutionTrigger