hasattr

Author: ian-sift

python/examples/ingestion_with_yaml_config/main.py

@@ -20,7 +20,7 @@
 
     load_dotenv()
 
-    apikey = os.getenv("SIFT_API_KEY")
+    apikey = os.getenv("SIFT_LOCAL_API_KEY")
 
     if apikey is None:
         raise Exception("Missing 'SIFT_API_KEY' environment variable.")
@@ -34,7 +34,7 @@
     telemetry_config = nostromos_lv_426()
 
     # Create a gRPC transport channel configured specifically for the Sift API
-    sift_channel_config = SiftChannelConfig(uri=base_uri, apikey=apikey)
+    sift_channel_config = SiftChannelConfig(uri=base_uri, apikey=apikey, use_ssl=False)
 
     with use_sift_channel(sift_channel_config) as channel:
         # Create ingestion service using the telemetry config we loaded in

python/lib/sift_py/yaml/utils.py

@@ -23,8 +23,7 @@ def try_fast_yaml_load(path: Path) -> Dict[Any, Any]:
     If the CSafeLoader is not available, use the pyyaml safe loader.
     """
     with open(path, "r") as f:
-        try:
-            loader = yaml.CSafeLoader
-            return cast(Dict[Any, Any], yaml.load(f.read(), Loader=loader))
-        except AttributeError:
+        if hasattr(yaml, "CSafeLoader"):
+            return cast(Dict[Any, Any], yaml.load(f.read(), Loader=yaml.CSafeLoader))
+        else:
             return cast(Dict[Any, Any], yaml.safe_load(f.read()))