From 7d0eeeb8024a6d5b2c4d1ab68a3a704b148b6d57 Mon Sep 17 00:00:00 2001 From: Teddy Date: Fri, 20 Jan 2023 15:33:55 +0100 Subject: [PATCH] Fix datetime fn mysql (#9825) * fix: mysql datetime function * empty commit to re-run tests --- .../metadata/orm_profiler/orm/functions/datetime.py | 10 ++++++++++ 1 file changed, 10 insertions(+) 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"""