fix(ingest/profiling) Fixing profile eligibility check (datahub-proje…

…ct#9446)
Salman-Apptware · Dec 15, 2023 · 4fea930 · 4fea930
1 parent 9222f88
commit 4fea930
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/sql/sql_generic_profiler.py b/metadata-ingestion/src/datahub/ingestion/source/sql/sql_generic_profiler.py
@@ -274,16 +274,16 @@ def is_dataset_eligible_for_profiling(
             return False
 
         if self.config.profiling.profile_table_size_limit is not None and (
-            size_in_bytes is None
-            or size_in_bytes / (2**30)
+            size_in_bytes is not None
+            and size_in_bytes / (2**30)
             > self.config.profiling.profile_table_size_limit
         ):
             self.report.profiling_skipped_size_limit[schema_name] += 1
             return False
 
         if self.config.profiling.profile_table_row_limit is not None and (
-            rows_count is None
-            or rows_count > self.config.profiling.profile_table_row_limit
+            rows_count is not None
+            and rows_count > self.config.profiling.profile_table_row_limit
         ):
             self.report.profiling_skipped_row_limit[schema_name] += 1
             return False