fix(lint): lib upgrade caused

datahub-project · Apr 28, 2022 · 37351c8 · 37351c8
1 parent 4458e62
commit 37351c8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/metadata-ingestion/src/datahub/emitter/mce_builder.py b/metadata-ingestion/src/datahub/emitter/mce_builder.py
@@ -4,7 +4,6 @@
 import os
 import re
 import time
-from distutils.util import strtobool
 from enum import Enum
 from hashlib import md5
 from typing import Any, List, Optional, Type, TypeVar, Union, cast, get_type_hints
@@ -40,8 +39,8 @@
 DEFAULT_ENV = DEFAULT_ENV_CONFIGURATION
 DEFAULT_FLOW_CLUSTER = "prod"
 UNKNOWN_USER = "urn:li:corpuser:unknown"
-DATASET_URN_TO_LOWER: bool = strtobool(
-    os.getenv("DATAHUB_DATASET_URN_TO_LOWER", "false")
+DATASET_URN_TO_LOWER: bool = (
+    os.getenv("DATAHUB_DATASET_URN_TO_LOWER", "false") == "true"
 )
 
 

diff --git a/metadata-ingestion/src/datahub/ingestion/source/looker.py b/metadata-ingestion/src/datahub/ingestion/source/looker.py
@@ -858,6 +858,7 @@ def get_workunits(self) -> Iterable[MetadataWorkUnit]:
             async_workunits = [
                 async_executor.submit(self.process_dashboard, dashboard_id)
                 for dashboard_id in dashboard_ids
+                if dashboard_id is not None
             ]
             for async_workunit in concurrent.futures.as_completed(async_workunits):
                 work_units, dashboard_id, start_time, end_time = async_workunit.result()