Skip to content

Commit 2cbae70

Browse files
committed
Cleaning up
1 parent fe99463 commit 2cbae70

1 file changed

Lines changed: 1 addition & 12 deletions

File tree

rust/operator-binary/src/env_vars.rs

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -288,23 +288,12 @@ pub fn build_airflow_statefulset_envs(
288288
}
289289

290290
pub fn get_dags_folder(git_sync_resources: &git_sync::v1alpha1::GitSyncResources) -> Vec<String> {
291-
// let git_sync_count = git_sync_resources.git_content_folders.len();
292-
// if git_sync_count > 1 {
293-
// tracing::warn!(
294-
// "There are {git_sync_count} git-sync entries: Only the first one will be considered.",
295-
// );
296-
// }
297291
let mut git_folders = Vec::<String>::new();
298292
// If DAG provisioning via git-sync is not configured, set a default value
299293
// so that PYTHONPATH can refer to it. N.B. nested variables need to be
300294
// resolved, so that /stackable/airflow is used instead of $AIRFLOW_HOME.
301295
// see https://airflow.apache.org/docs/apache-airflow/stable/configurations-ref.html#dags-folder
302-
// git_sync_resources
303-
// .git_content_folders_as_string()
304-
// .first()
305-
// .cloned()
306-
// .unwrap_or("/stackable/airflow/dags".to_string())
307-
// TODO: Might need check weather path is correct.
296+
308297
for folder in git_sync_resources.git_content_folders_as_string() {
309298
git_folders.push(folder)
310299
}

0 commit comments

Comments
 (0)