fix: Fix dozer connectors

dozer-cli/src/cli/helper.rs

@@ -63,7 +63,7 @@ pub async fn list_sources(
 ) -> Result<(), OrchestrationError> {
     let config = init_config(config_paths, config_token, config_overrides, ignore_pipe).await?;
     let dozer = init_dozer(runtime, config, Default::default())?;
-    let connection_map = dozer.list_connectors()?;
+    let connection_map = dozer.list_connectors().await?;
     let mut table_parent = Table::new();
     for (connection_name, (tables, schemas)) in connection_map {
         let mut first_table_found = false;

dozer-cli/src/simple/orchestrator.rs

@@ -276,19 +276,17 @@ impl SimpleOrchestrator {
     }
 
     #[allow(clippy::type_complexity)]
-    pub fn list_connectors(
+    pub async fn list_connectors(
         &self,
     ) -> Result<HashMap<String, (Vec<TableInfo>, Vec<SourceSchema>)>, OrchestrationError> {
-        self.runtime.block_on(async {
-            let mut schema_map = HashMap::new();
-            for connection in &self.config.connections {
-                let connector = get_connector(connection.clone())?;
-                let schema_tuples = connector.list_all_schemas().await?;
-                schema_map.insert(connection.name.clone(), schema_tuples);
-            }
+        let mut schema_map = HashMap::new();
+        for connection in &self.config.connections {
+            let connector = get_connector(connection.clone())?;
+            let schema_tuples = connector.list_all_schemas().await?;
+            schema_map.insert(connection.name.clone(), schema_tuples);
+        }
 
-            Ok(schema_map)
-        })
+        Ok(schema_map)
     }
 
     pub fn generate_token(&self, ttl_in_secs: Option<i32>) -> Result<String, OrchestrationError> {

dozer-sql/src/errors.rs

@@ -115,9 +115,6 @@ pub enum PipelineError {
     )]
     UnsupportedJoinConstraintOperator(String),
 
-    #[error("Invalid Field specified in JOIN: {0}")]
-    InvalidFieldSpecified(String),
-
     #[error("Currently JOIN supports two level of namespacing. For example, `source.field_name` is valid, but `connection.source.field_name` is not.")]
     NameSpaceTooLong(String),