Moved doc parsing to server side

Author: aritra24

task-sdk/src/airflow/sdk/definitions/dag.py

@@ -185,7 +185,18 @@ def _convert_doc_md(doc_md: str | None) -> str | None:
                 return fh.read()
         except FileNotFoundError:
             return doc_md
+    return doc_md
+
 
+def _clean_doc_md(doc_md: str) -> str:
+    # alternative to using math.inf, the linter doesn't like inf being a float
+    strip_count = len(doc_md)
+
+    for line in doc_md.split("\n"):
+        if line != "":
+            strip_count = min(strip_count, len(line) - len(line.lstrip()))
+    if strip_count > 0:
+        doc_md = "\n".join([line[strip_count:] for line in doc_md.split("\n")])
     return doc_md
 
 
@@ -1120,8 +1131,7 @@ def factory(*args, **kwargs):
             with DAG(dag_id, **decorator_kwargs) as dag_obj:
                 # Set DAG documentation from function documentation if it exists and doc_md is not set.
                 if f.__doc__ and not dag_obj.doc_md:
-                    dag_obj.doc_md = f.__doc__
-
+                    dag_obj.doc_md = _clean_doc_md(f.__doc__)
                 # Generate DAGParam for each function arg/kwarg and replace it for calling the function.
                 # All args/kwargs for function will be DAGParam object and replaced on execution time.
                 f_kwargs = {}