We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e810ddc commit b48afecCopy full SHA for b48afec
1 file changed
ingestion/src/metadata/ingestion/lineage/parser.py
@@ -12,6 +12,7 @@
12
Lineage Parser configuration
13
"""
14
import hashlib
15
+import re
16
import time
17
import traceback
18
from collections import defaultdict
@@ -504,8 +505,6 @@ def clean_raw_query(cls, raw_query: str) -> Optional[str]:
504
505
query from logs, etc.), perform a cleaning step
506
before passing it to the LineageRunner
507
- import re
508
-
509
clean_query = insensitive_replace(
510
raw_str=raw_query,
511
to_replace=" copy grants ", # snowflake specific
0 commit comments