16 duplicated lines in:
  - modules/data/data_pipeline_run.py (62:82, 31%)
  - modules/monitoring/monitor_pipeline_run.py (73:93, 26%)

15 duplicated lines in:
  - modules/data/data_pipeline_create.py (79:98, 25%)
  - modules/monitoring/monitor_pipeline_create.py (84:103, 21%)

11 duplicated lines in:
  - modules/data/data_pipeline_create.py (33:53, 18%)
  - modules/monitoring/monitor_pipeline_create.py (34:54, 15%)

11 duplicated lines in:
  - modules/data/data_pipeline_define.py (50:63, 15%)
  - modules/monitoring/monitor_pipeline_define.py (53:69, 9%)

10 duplicated lines in:
  - modules/data/data_pipeline_define.py (91:104, 13%)
  - modules/monitoring/monitor_pipeline_define.py (141:154, 8%)

9 duplicated lines in:
  - modules/data/data_pipeline_define.py (12:35, 12%)
  - modules/monitoring/monitor_pipeline_define.py (15:38, 7%)

8 duplicated lines in:
  - modules/data/data_pipeline_define.py (63:71, 11%)
  - modules/monitoring/monitor_pipeline_define.py (74:82, 7%)

8 duplicated lines in:
  - modules/data/data_pipeline_define.py (63:71, 11%)
  - modules/monitoring/monitor_pipeline_define.py (116:124, 7%)

7 duplicated lines in:
  - modules/data/data_pipeline_create.py (6:31, 11%)
  - modules/monitoring/monitor_pipeline_create.py (7:32, 10%)

6 duplicated lines in:
  - modules/data/data_pipeline_define.py (12:17, 8%)
  - modules/monitoring/monitor_pipeline_create.py (62:67, 8%)

6 duplicated lines in:
  - modules/data/data_pipeline_create.py (59:64, 10%)
  - modules/monitoring/monitor_pipeline_create.py (62:67, 8%)

6 duplicated lines in:
  - modules/data/data_pipeline_define.py (108:113, 8%)
  - modules/monitoring/monitor_pipeline_define.py (159:164, 5%)

6 duplicated lines in:
  - modules/data/data_pipeline_run.py (42:47, 11%)
  - modules/monitoring/monitor_pipeline_run.py (43:48, 9%)

6 duplicated lines in:
  - modules/data/data_pipeline_run.py (84:89, 11%)
  - modules/monitoring/monitor_pipeline_run.py (95:100, 9%)

6 duplicated lines in:
  - modules/data/data_pipeline_create.py (59:64, 10%)
  - modules/monitoring/monitor_pipeline_define.py (15:20, 5%)