Luigi is a Python module that helps you build complex pipelines of batch jobs. It handles dependency resolution, workflow management, visualization etc. It also comes with Hadoop support built in.
1381 matches across 16 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/notifications_test.py | 143 | def test_generate_unicode_email(self): |
| LOW | test/notifications_test.py | 243 | def test_sends_smtp_email_without_tls(self): |
| LOW | test/notifications_test.py | 276 | def test_sends_smtp_email_exceptions(self): |
| LOW | test/notifications_test.py | 311 | def test_sends_sendgrid_email(self): |
| LOW | test/notifications_test.py | 380 | def test_sns_subject_is_shortened(self): |
| LOW | test/optional_parameter_test.py | 56 | def test_optional_int_parameter(self): |
| LOW | test/optional_parameter_test.py | 61 | def test_optional_bool_parameter(self): |
| LOW | test/optional_parameter_test.py | 66 | def test_optional_float_parameter(self): |
| LOW | test/optional_parameter_test.py | 71 | def test_optional_dict_parameter(self): |
| LOW | test/optional_parameter_test.py | 76 | def test_optional_list_parameter(self): |
| LOW | test/optional_parameter_test.py | 81 | def test_optional_tuple_parameter(self): |
| LOW | test/optional_parameter_test.py | 86 | def test_optional_numerical_parameter_float(self): |
| LOW | test/optional_parameter_test.py | 91 | def test_optional_numerical_parameter_int(self): |
| LOW | test/optional_parameter_test.py | 96 | def test_optional_choice_parameter(self): |
| LOW | test/optional_parameter_test.py | 102 | def test_optional_choice_parameter_int(self): |
| LOW | test/scheduler_message_test.py | 86 | def test_receive_messages_disabled(self): |
| LOW | test/scheduler_message_test.py | 103 | def test_send_messages_disabled(self): |
| LOW | test/interface_test.py | 67 | def _summary_dict_module_path(): |
| LOW | test/interface_test.py | 70 | def test_interface_run_positive_path(self): |
| LOW | test/interface_test.py | 75 | def test_interface_run_positive_path_with_detailed_summary_enabled(self): |
| LOW | test/interface_test.py | 80 | def test_interface_run_with_add_failure(self): |
| LOW | test/interface_test.py | 85 | def test_interface_run_with_add_failure_with_detailed_summary_enabled(self): |
| LOW | test/interface_test.py | 90 | def test_interface_run_with_run_failure(self): |
| LOW | test/interface_test.py | 95 | def test_interface_run_with_run_failure_with_detailed_summary_enabled(self): |
| LOW | test/interface_test.py | 101 | def test_that_status_is_success(self, fake_summary_dict): |
| LOW | test/interface_test.py | 108 | def test_that_status_is_success_with_retry(self, fake_summary_dict): |
| LOW | test/interface_test.py | 115 | def test_that_status_is_failed_when_there_is_one_failed_task(self, fake_summary_dict): |
| LOW | test/interface_test.py | 122 | def test_that_status_is_failed_with_scheduling_failure(self, fake_summary_dict): |
| LOW | test/interface_test.py | 131 | def test_that_status_is_scheduling_failed_with_one_scheduling_error(self, fake_summary_dict): |
| LOW | test/interface_test.py | 138 | def test_that_status_is_not_run_with_one_task_not_run(self, fake_summary_dict): |
| LOW | test/interface_test.py | 145 | def test_that_status_is_missing_ext_with_one_task_with_missing_external_dependency(self, fake_summary_dict): |
| LOW | test/interface_test.py | 151 | def test_stops_worker_on_add_exception(self): |
| LOW | test/interface_test.py | 159 | def test_stops_worker_on_run_exception(self): |
| LOW | test/interface_test.py | 168 | def test_just_run_main_task_cls(self): |
| LOW | test/interface_test.py | 181 | def test_run_with_int_raises_type_error(self): |
| LOW | test/interface_test.py | 187 | def test_run_with_dict_raises_type_error(self): |
| LOW | test/interface_test.py | 193 | def test_run_with_none_does_not_raise_type_error(self): |
| LOW | test/interface_test.py | 201 | def test_run_with_valid_list_does_not_raise_type_error(self): |
| LOW | test/interface_test.py | 215 | def test_parallel_scheduling_processes_default(self): |
| LOW | test/interface_test.py | 219 | def test_parallel_scheduling_processes(self): |
| LOW | test/interface_test.py | 48 | def _create_summary_dict_with(self, updates={}): |
| LOW | test/task_forwarded_attributes_test.py | 31 | def gather_forwarded_attributes(self): |
| LOW | test/conftest.py | 25 | def pytest_collection_modifyitems(items: List[pytest.Item]) -> None: |
| LOW | test/choice_parameter_test.py | 43 | def test_choices_parameter_exception(self): |
| LOW | test/scheduler_api_test.py | 304 | def test_get_work_with_unbatched_worker_on_batched_task(self): |
| LOW | test/scheduler_api_test.py | 314 | def test_batched_tasks_become_batch_running(self): |
| LOW | test/scheduler_api_test.py | 321 | def test_downstream_jobs_from_batch_running_have_upstream_running_status(self): |
| LOW | test/scheduler_api_test.py | 331 | def test_set_batch_runner_new_task(self): |
| LOW | test/scheduler_api_test.py | 402 | def test_batch_fail_from_dead_worker(self): |
| LOW | test/scheduler_api_test.py | 409 | def test_batch_fail_max_from_dead_worker(self): |
| LOW | test/scheduler_api_test.py | 416 | def test_batch_fail_from_dead_worker_without_running(self): |
| LOW | test/scheduler_api_test.py | 468 | def test_resend_batch_on_get_work_retry(self): |
| LOW | test/scheduler_api_test.py | 478 | def test_resend_batch_runner_on_get_work_retry(self): |
| LOW | test/scheduler_api_test.py | 483 | def test_resend_max_batch_runner_on_get_work_retry(self): |
| LOW | test/scheduler_api_test.py | 488 | def test_do_not_resend_batch_runner_on_get_work(self): |
| LOW | test/scheduler_api_test.py | 493 | def test_do_not_resend_max_batch_runner_on_get_work(self): |
| LOW | test/scheduler_api_test.py | 498 | def test_rescheduled_batch_running_tasks_stay_batch_running_before_runner(self): |
| LOW | test/scheduler_api_test.py | 508 | def test_rescheduled_batch_running_tasks_stay_batch_running_after_runner(self): |
| LOW | test/scheduler_api_test.py | 514 | def test_disabled_batch_running_tasks_stay_batch_running_before_runner(self): |
| LOW | test/scheduler_api_test.py | 524 | def test_get_work_returns_batch_task_id_list(self): |
| 831 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/task_bulk_complete_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/notifications_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/scheduler_message_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/dict_parameter_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/most_common_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/interface_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/dynamic_import_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/task_forwarded_attributes_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/choice_parameter_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/scheduler_api_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/util_previous_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/event_callbacks_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/scheduler_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/clone_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/list_parameter_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/config_env_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/scheduler_parameter_visibilities_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/range_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/set_task_name_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/parameter_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/_mysqldb_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/lock_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/test_sigpipe.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/date_interval_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/decorator_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/scheduler_visualisation_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/recursion_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/worker_external_task_test.py | 1 | # Copyright (c) 2015 |
| LOW | test/local_target_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/target_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/task_running_resources_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/subtask_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/worker_task_process_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/task_history_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/worker_scheduler_com_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/util_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/custom_metrics_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/task_progress_percentage_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/worker_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/helpers_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/test_ssh.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/factorial_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/worker_task_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/db_task_history_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/fib_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/config_toml_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/_test_ftp.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/task_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/wrap_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/instance_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/import_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/safe_extractor_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/rpc_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/retcodes_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/other_module.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/simulate_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/worker_parallel_scheduling_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/server_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/date_parameter_test.py | 1 | # -*- coding: utf-8 -*- |
| LOW | test/numerical_parameter_test.py | 1 | # -*- coding: utf-8 -*- |
| 174 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | test/contrib/redshift_test.py | 0 | copy {table} {colnames} from '{source}' credentials '{creds}' {options} ; |
| HIGH | test/contrib/redshift_test.py | 0 | copy {table} {colnames} from '{source}' credentials '{creds}' {options} ; |
| HIGH | test/contrib/redshift_test.py | 0 | copy {table} {colnames} from '{source}' credentials '{creds}' {options} ; |
| HIGH | luigi/contrib/redshift.py | 0 | copy {table} {colnames} from '{source}' credentials '{creds}' {options} ; |
| HIGH | luigi/tools/range.py | 0 | given a date-time, will produce a dictionary of of-params combined with the ranged task parameter |
| HIGH | luigi/tools/range.py | 0 | given a date-time, will produce a dictionary of of-params combined with the ranged task parameter |
| HIGH | luigi/tools/range.py | 0 | given a date-time, will produce a dictionary of of-params combined with the ranged task parameter |
| HIGH | luigi/tools/range.py | 0 | given a date-time, will produce a dictionary of of-params combined with the ranged task parameter |
| HIGH | luigi/tools/range.py | 0 | given a date-time, will produce a dictionary of of-params combined with the ranged task parameter |
| HIGH | luigi/tools/range.py | 0 | given a dictionary of parameters, will extract the ranged task parameter value |
| HIGH | luigi/tools/range.py | 0 | given a dictionary of parameters, will extract the ranged task parameter value |
| HIGH | luigi/tools/range.py | 0 | given a dictionary of parameters, will extract the ranged task parameter value |
| HIGH | luigi/tools/range.py | 0 | given a dictionary of parameters, will extract the ranged task parameter value |
| HIGH | luigi/tools/range.py | 0 | given a dictionary of parameters, will extract the ranged task parameter value |
| HIGH | luigi/contrib/redshift.py | 0 | this update id will be a unique identifier for this insert on this table. |
| HIGH | luigi/contrib/sqla.py | 0 | this update id will be a unique identifier for this insert on this table. |
| HIGH | luigi/contrib/rdbms.py | 0 | this update id will be a unique identifier for this insert on this table. |
| HIGH | luigi/contrib/sqla.py | 0 | create marker table if it doesn't exist. using a separate connection since the transaction might have to be reset. |
| HIGH | luigi/contrib/mysqldb.py | 0 | create marker table if it doesn't exist. using a separate connection since the transaction might have to be reset. |
| HIGH | luigi/contrib/postgres.py | 0 | create marker table if it doesn't exist. using a separate connection since the transaction might have to be reset. |
| HIGH | luigi/contrib/bigquery.py | 0 | set additional job configuration. this allows to specify job configuration parameters that are not exposed via task prop |
| HIGH | luigi/contrib/bigquery.py | 0 | set additional job configuration. this allows to specify job configuration parameters that are not exposed via task prop |
| HIGH | luigi/contrib/bigquery.py | 0 | set additional job configuration. this allows to specify job configuration parameters that are not exposed via task prop |
| HIGH | examples/elasticsearch_index.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/wordcount.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/dynamic_requirements.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/dynamic_requirements.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/dynamic_requirements.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/top_artists.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/top_artists.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file on the loc |
| HIGH | examples/wordcount.py | 0 | this class represents something that was created elsewhere by an external process, so all we want to do is to implement |
| HIGH | examples/ftp_experiment_outputs.py | 0 | this class represents something that was created elsewhere by an external process, so all we want to do is to implement |
| HIGH | examples/ftp_experiment_outputs.py | 0 | this class represents something that was created elsewhere by an external process, so all we want to do is to implement |
| HIGH | examples/terasort.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| HIGH | examples/terasort.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| HIGH | examples/spark_als.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| HIGH | examples/spark_als.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| HIGH | examples/wordcount_hadoop.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| HIGH | examples/top_artists.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| HIGH | examples/top_artists.py | 0 | returns the target output for this task. in this case, a successful execution of this task will create a file in hdfs. : |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/notifications_test.py | 191 | |
| LOW | test/notifications_test.py | 305 | |
| LOW | test/notifications_test.py | 331 | |
| LOW | test/notifications_test.py | 360 | |
| LOW | …archive_root/package/submodule_with_absolute_import.py | 18 | |
| LOW | test/create_packages_archive_root/package/submodule.py | 18 | |
| LOW | …_packages_archive_root/package/subpackage/submodule.py | 18 | |
| LOW | luigi/task.py | 23 | |
| LOW | luigi/task.py | 38 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 21 | |
| LOW | luigi/__init__.py | 23 | |
| LOW | luigi/__init__.py | 24 | |
| LOW | luigi/__init__.py | 25 | |
| LOW | luigi/__init__.py | 25 | |
| LOW | luigi/__init__.py | 26 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 27 | |
| LOW | luigi/__init__.py | 63 | |
| LOW | luigi/__init__.py | 63 | |
| LOW | luigi/__init__.py | 64 | |
| LOW | luigi/__init__.py | 65 | |
| LOW | luigi/__init__.py | 65 | |
| 17 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/parameter_test.py | 117 | |
| LOW | test/target_test.py | 287 | |
| LOW | test/fib_test.py | 39 | |
| LOW | test/contrib/hadoop_jar_test.py | 92 | |
| LOW | test/contrib/hadoop_jar_test.py | 95 | |
| LOW | luigi/worker.py | 172 | |
| LOW | luigi/worker.py | 514 | |
| LOW | luigi/worker.py | 772 | |
| LOW | luigi/worker.py | 832 | |
| LOW | luigi/worker.py | 1082 | |
| LOW | luigi/worker.py | 1159 | |
| LOW | luigi/worker.py | 1204 | |
| LOW | luigi/metrics.py | 14 | |
| LOW | luigi/task.py | 953 | |
| LOW | luigi/task.py | 772 | |
| LOW | luigi/util.py | 426 | |
| LOW | luigi/format.py | 55 | |
| LOW | luigi/mypy.py | 86 | |
| LOW | luigi/mypy.py | 100 | |
| LOW | luigi/db_task_history.py | 250 | |
| LOW | luigi/lock.py | 30 | |
| LOW | luigi/execution_summary.py | 179 | |
| LOW | luigi/execution_summary.py | 371 | |
| LOW | luigi/execution_summary.py | 467 | |
| LOW | luigi/scheduler.py | 1066 | |
| LOW | luigi/scheduler.py | 1139 | |
| LOW | luigi/scheduler.py | 1291 | |
| LOW | luigi/scheduler.py | 1360 | |
| LOW | luigi/scheduler.py | 1519 | |
| LOW | luigi/scheduler.py | 1648 | |
| LOW | luigi/tools/deps.py | 94 | |
| LOW | luigi/contrib/redshift.py | 287 | |
| LOW | luigi/contrib/beam_dataflow.py | 388 | |
| LOW | luigi/contrib/sqla.py | 323 | |
| LOW | luigi/contrib/salesforce.py | 55 | |
| LOW | luigi/contrib/salesforce.py | 149 | |
| LOW | luigi/contrib/salesforce.py | 207 | |
| LOW | luigi/contrib/hadoop.py | 88 | |
| LOW | luigi/contrib/hadoop.py | 112 | |
| LOW | luigi/contrib/hadoop.py | 238 | |
| LOW | luigi/contrib/hadoop.py | 266 | |
| LOW | luigi/contrib/hadoop.py | 931 | |
| LOW | luigi/contrib/sge.py | 298 | |
| LOW | luigi/contrib/hive.py | 393 | |
| LOW | luigi/contrib/pig.py | 127 | |
| LOW | luigi/contrib/external_program.py | 138 | |
| LOW | luigi/contrib/kubernetes.py | 267 | |
| LOW | luigi/contrib/postgres.py | 357 | |
| LOW | luigi/contrib/presto.py | 57 | |
| LOW | luigi/contrib/lsf.py | 276 | |
| LOW | luigi/contrib/s3.py | 584 | |
| LOW | luigi/contrib/hdfs/hadoopcli_clients.py | 170 | |
| LOW | luigi/contrib/hdfs/target.py | 150 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | test/interface_test.py | 193 | def test_run_with_none_does_not_raise_type_error(self): |
| LOW | test/interface_test.py | 206 | except Exception: |
| LOW | test/db_task_history_test.py | 112 | except Exception: |
| MEDIUM | test/db_task_history_test.py | 109 | def setUp(self): |
| LOW | test/worker_parallel_scheduling_test.py | 177 | except Exception as e: |
| LOW | test/contrib/docker_runner_test.py | 51 | except Exception: |
| MEDIUM | test/contrib/dropbox_test.py | 172 | def test_mkdir_recreate_dir(self): |
| MEDIUM | test/contrib/dropbox_test.py | 186 | def test_mkdir_recreate_slashed_dir(self): |
| LOW | test/contrib/dropbox_test.py | 175 | except Exception as ex: |
| LOW | test/contrib/dropbox_test.py | 180 | except Exception as ex: |
| LOW | test/contrib/dropbox_test.py | 189 | except Exception as ex: |
| LOW | test/contrib/dropbox_test.py | 194 | except Exception as ex: |
| LOW | test/contrib/postgres_with_server_test.py | 55 | except Exception: |
| LOW | test/contrib/mongo_test.py | 36 | except Exception: |
| LOW | test/contrib/test_ssh.py | 57 | except Exception: |
| LOW | test/contrib/test_ssh.py | 69 | except Exception: |
| MEDIUM | test/contrib/test_ssh.py | 66 | def tearDown(self): |
| LOW | test/contrib/esindex_test.py | 64 | except Exception: |
| LOW | luigi/worker.py | 441 | except Exception: |
| LOW | luigi/worker.py | 705 | except Exception: |
| LOW | luigi/worker.py | 806 | except Exception as ex: |
| LOW | luigi/worker.py | 876 | except Exception as ex: |
| LOW | luigi/worker.py | 956 | except Exception as ex: |
| MEDIUM | luigi/worker.py | 393 | def get(self, block=None, timeout=None): |
| LOW | luigi/task.py | 441 | except Exception as exc: |
| LOW | luigi/retcodes.py | 83 | except Exception: |
| LOW | luigi/contrib/sqla.py | 361 | except Exception as e: |
| LOW | luigi/contrib/hadoop.py | 291 | except Exception as e: |
| LOW | luigi/contrib/hadoop.py | 324 | except Exception as e: |
| LOW | luigi/contrib/hadoop.py | 368 | except Exception as e: |
| LOW | luigi/contrib/bigquery_avro.py | 64 | except Exception as e: |
| LOW | luigi/contrib/bigquery_avro.py | 106 | except Exception as e: |
| LOW | luigi/contrib/mrrunner.py | 89 | except Exception as exc: |
| LOW | luigi/contrib/lsf_runner.py | 73 | except Exception as exc: |
| LOW | luigi/contrib/dropbox.py | 82 | except Exception as e: |
| LOW | luigi/contrib/presto.py | 178 | except Exception: |
| LOW | luigi/contrib/ssh.py | 289 | except Exception: |
| LOW | luigi/contrib/sge_runner.py | 87 | except Exception as e: |
| LOW | luigi/contrib/hdfs/format.py | 52 | except Exception as ex: |
| LOW | luigi/contrib/hdfs/format.py | 82 | except Exception as ex: |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | test/rpc_test.py | 117 | fetch_results = ['{"response": null}', '{"response": {"pass": true}}'] |
| HIGH | test/rpc_test.py | 125 | fetch_results = ['{"response": null}'] * 3 + ['{"response": {}}'] |
| HIGH | test/contrib/pai_test.py | 51 | command = "cd scikit-learn/benchmarks && python bench_mnist.py" |
| HIGH | test/contrib/pai_test.py | 53 | tasks = [TaskRole("test", "cd scikit-learn/benchmarks && python bench_mnist.py", memoryMB=4096)] |
| HIGH | test/contrib/bigquery_gcloud_test.py | 403 | "default":null, |
| HIGH | test/contrib/bigquery_gcloud_test.py | 414 | "default":null, |
| HIGH | luigi/parameter.py | 1298 | of parsing. The traversal order of standard ``dict`` is undefined, which can result various string |
| HIGH | luigi/contrib/ssh.py | 141 | ["-L", tunnel_host, "echo -n ready && cat"], |
| Severity | File | Line | Snippet |
|---|---|---|---|
| CRITICAL | test/server_test.py | 477 | self.mock_scheduler._state._metrics_collector.configure_http_handler.assert_called_once_with(self.handler) |
| CRITICAL | test/contrib/spark_test.py | 411 | spark.sql.return_value.write.saveAsTable.assert_called_with("output") |
| CRITICAL | luigi/static/visualiser/lib/jquery-1.10.0.min.js | 5 | if(c&&u[c]&&(i||u[c].data)||r!==t||"string"!=typeof n)return c||(c=l?e[s]=p.pop()||x.guid++:s),u[c]||(u[c]=l?{}:{toJSON: |
| CRITICAL | …aliser/lib/jquery-ui/js/jquery-ui-1.10.3.custom.min.js | 6 | (function(e,t){function i(t,i){var a,n,r,o=t.nodeName.toLowerCase();return"area"===o?(a=t.parentNode,n=a.name,t.href&&n& |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/conftest.py | 33 | # Check if the item has any markers (custom or builtin) |
| LOW | test/safe_extractor_test.py | 88 | # Check if the file exists |
| LOW | test/safe_extractor_test.py | 91 | # Check if the file content is correct |
| LOW | test/contrib/redshift_test.py | 245 | # Check if the `S3CopyToTable.s3_load_path` class attribute was |
| LOW | test/contrib/redshift_test.py | 360 | # Check if the `S3CopyToTable.s3_load_path` class attribute was |
| LOW | test/contrib/spark_test.py | 369 | # Check if find_class finds the class for the correct module name. |
| LOW | test/contrib/spark_test.py | 401 | # Check if find_class finds the class for the correct module name. |
| LOW | luigi/util.py | 294 | # Check if the parameter exists in the inheriting task |
| LOW | luigi/mypy.py | 129 | # Check if a 'default' argument is explicitly provided |
| LOW | luigi/parameter.py | 1803 | # Output message in new file |
| LOW | luigi/contrib/sqla.py | 321 | reflect = False # Set this to true only if the table has already been created by alternate means |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | test/safe_extractor_test.py | 101 | # Create a tar file with 3 files |
| MEDIUM | test/safe_extractor_test.py | 115 | # Create a tar file with a path traversal file |
| MEDIUM | luigi/lock.py | 100 | # Create a pid file if it does not exist |
| MEDIUM | doc/conf.py | 6 | # This file is execfile()d with the current directory set to its |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/contrib/s3_test.py | 593 | # we can just use this key |
| LOW | luigi/worker.py | 72 | # unscientifically just set the final value to a floating point number that |
| LOW | luigi/lock.py | 141 | # If the file happen to not exist, simply return |
| LOW | luigi/contrib/hdfs/config.py | 113 | # just return any random temporary location |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/contrib/gcs_test.py | 145 | lorem = b"Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt\ |
| LOW | test/contrib/gcs_test.py | 145 | lorem = b"Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt\ |
| LOW | test/contrib/gcs_test.py | 160 | lorem = b"Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt\ |
| LOW | test/contrib/gcs_test.py | 160 | lorem = b"Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh euismod tincidunt\ |
| LOW | test/contrib/mongo_test.py | 166 | {"_id": "person_1", "age": 11, "experience": 10, "content": "Lorem ipsum, dolor sit amet. Consectetur adipis |
| LOW | test/contrib/mongo_test.py | 166 | {"_id": "person_1", "age": 11, "experience": 10, "content": "Lorem ipsum, dolor sit amet. Consectetur adipis |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | test/task_forwarded_attributes_test.py | 65 | def run_task(self, task): |
| LOW | test/scheduler_test.py | 366 | def run_task(self): |
| LOW | test/db_task_history_test.py | 97 | def run_task(self, task): |
| LOW | test/db_task_history_test.py | 139 | def run_task(self, task): |
| LOW | test/execution_summary_test.py | 36 | def run_task(self, task): |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | test/execution_summary_test.py | 160 | |
| MEDIUM | test/execution_summary_test.py | 263 |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | test/visualiser/visualiser_test.py | 319 | # --------------------------------------------------------------------------- |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | luigi/contrib/ssh.py | 145 | # make sure to get the data so we know the connection is established |