@@ -744,11 +744,9 @@ def generate_physical_dataset_lineage(
744
744
# To generate column level lineage, we can manually decode the metadata
745
745
# to produce the ColumnLineageInfo
746
746
columns = dataset_response .get ("result" , {}).get ("columns" , [])
747
- print (f"\n \n columns are: { columns } \n \n " )
748
747
cll : List [ColumnLineageInfo ] = []
749
748
750
749
for column in columns :
751
- print ("\n was here\n " )
752
750
cll .append (
753
751
ColumnLineageInfo (
754
752
downstream = DownstreamColumnRef (
@@ -765,9 +763,7 @@ def generate_physical_dataset_lineage(
765
763
logic = None ,
766
764
)
767
765
)
768
- print (f"\n \n cll now is: { cll } \n \n " )
769
766
770
- print (f"\n \n cll is; { cll } \n \n " )
771
767
fine_grained_lineages : List [FineGrainedLineageClass ] = []
772
768
773
769
for cll_info in cll :
@@ -798,7 +794,6 @@ def generate_physical_dataset_lineage(
798
794
],
799
795
fineGrainedLineages = fine_grained_lineages ,
800
796
)
801
- print (f"\n \n at the end, column level lineage is; { upstream_lineage } \n \n " )
802
797
return upstream_lineage
803
798
804
799
def construct_dataset_from_dataset_data (
@@ -860,7 +855,6 @@ def construct_dataset_from_dataset_data(
860
855
platform_instance = None ,
861
856
env = self .config .env ,
862
857
)
863
- print (f"\n \n \n parsed query object: { parsed_query_object .column_lineage } " )
864
858
upstream_lineage = self .generate_virtual_dataset_lineage (
865
859
parsed_query_object , datasource_urn
866
860
)
0 commit comments