diff --git a/ingestion/src/metadata/orm_profiler/orm/functions/datetime.py b/ingestion/src/metadata/orm_profiler/orm/functions/datetime.py index fcf76d6ab0d..aa2361725d1 100644 --- a/ingestion/src/metadata/orm_profiler/orm/functions/datetime.py +++ b/ingestion/src/metadata/orm_profiler/orm/functions/datetime.py @@ -104,6 +104,16 @@ def _(elements, compiler, **kwargs): ) +@compiles(DatetimeAddFn, Dialects.MySQL) +def _(elements, compiler, **kwargs): + """MySQL date and datetime function""" + interval = elements.clauses.clauses[0].value + interval_unit = compiler.process(elements.clauses.clauses[1], **kwargs) + return ( + f"CAST(CURRENT_TIMESTAMP - interval '{interval}' {interval_unit} AS DATETIME)" + ) + + @compiles(DatetimeAddFn, Dialects.BigQuery) def _(elements, compiler, **kwargs): """generic date and datetime function"""