Airflow는 목적에 따라 직렬, 병렬로 Task를 배치 및 실행 가능하다.
그 중 Dynamic Tasks는 Dag에서 병렬의 개수를 미리 정하지 않아도,
Task가 실행하는 메서드와 연결되어 유연한 병렬 Task 실행을 도와준다.
이 때 Command 생성을 위해 사용하는 메서드에 @Task 데코레이터를 사용해 개별 Task를 생성할 수 있고,
데코레이터 없이 메서드를 생성한 후, 실행하는 Operator만 운영할 수도 있다.
Command Task → Dynamic Tasks 구조로 연결된 경우 앞선 Command Task가 정상적으로 수행되면
여기서의 xcom 결과를 받아 따라오는 Dynamic Task가 실행되어야 하지만 Skip 되는 에러가 발생.
결론적으로 Command Task의 결과가 None 값을 보내주면
Command Task는 Success로 마킹한 채로 Dynamic Task로 넘어가지만,
Dynamic Task에서 실행할 병렬 Task는 0개이므로, 이 전체 Tasks는 Skipped로 처리된다.
어느 Task에서도 에러로 표기해주지 않아 문제 원인을 정확히 파악하는데 시간이 많이 걸렸다.