Index

A

abort() (luigi.contrib.hdfs.format.HdfsAtomicWriteDirPipe method) (luigi.contrib.hdfs.format.HdfsAtomicWritePipe method) (luigi.format.OutputPipeProcessWrapper method) abort_job() (luigi.contrib.salesforce.SalesforceAPI method) AbstractPySparkRunner (class in luigi.contrib.pyspark_runner) accept_trailing_slash() (in module luigi.contrib.dropbox) accept_trailing_slash_in_existing_dirpaths() (in module luigi.contrib.dropbox) accepts_messages (luigi.Task attribute) (luigi.task.Task attribute) acquire_for() (in module luigi.lock) active_deadline_seconds (luigi.contrib.kubernetes.KubernetesJobTask attribute) add() (luigi.contrib.opener.OpenerRegistry method) (luigi.scheduler.OrderedSet method) (luigi.worker.Worker method) add_config_path() (in module luigi.configuration) (in module luigi.configuration.core) (luigi.configuration.base_parser.BaseParser class method) add_disable() (luigi.batch_notifier.BatchNotifier method) add_failure() (luigi.batch_notifier.BatchNotifier method) (luigi.scheduler.Failures method) (luigi.scheduler.Task method) add_info() (luigi.scheduler.Worker method) add_link() (luigi.contrib.hadoop.JobTask method) add_rpc_message() (luigi.scheduler.Worker method) add_scheduler_message_response() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) add_scheduling_fail() (luigi.batch_notifier.BatchNotifier method) add_task() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) add_task_batcher() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) add_worker() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) ALL_METHOD_NAMES (luigi.contrib.target.CascadingClient attribute) allow_any_origin (luigi.server.cors attribute) allow_credentials (luigi.server.cors attribute) allow_jagged_rows (luigi.contrib.bigquery.BigQueryLoadTask attribute) allow_null_origin (luigi.server.cors attribute) allow_quoted_new_lines (luigi.contrib.bigquery.BigQueryLoadTask attribute) allowed_headers (luigi.server.cors attribute) allowed_kwargs (luigi.contrib.opener.LocalOpener attribute) (luigi.contrib.opener.MockOpener attribute) (luigi.contrib.opener.Opener attribute) (luigi.contrib.opener.S3Opener attribute) allowed_methods (luigi.server.cors attribute) allowed_origins (luigi.server.cors attribute)

AllRunHandler (class in luigi.server) already_running (luigi.retcodes.retcode attribute) always_log_stderr (luigi.contrib.external_program.ExternalProgramTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) AMBIGUOUS_CLASS (luigi.task_register.Register attribute) announce_scheduling_failure() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) ApacheHiveCommandClient (class in luigi.contrib.hive) api_key (luigi.contrib.datadog_metric.datadog attribute) API_NS (luigi.contrib.salesforce.SalesforceAPI attribute) API_VERSION (luigi.contrib.salesforce.SalesforceAPI attribute) apikey (luigi.notifications.sendgrid attribute) app (luigi.contrib.spark.PySparkTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) app() (in module luigi.server) app_command() (luigi.contrib.spark.PySparkTask method) (luigi.contrib.spark.SparkSubmitTask method) app_key (luigi.contrib.datadog_metric.datadog attribute) app_options() (luigi.contrib.spark.SparkSubmitTask method) apply_async() (luigi.worker.SingleProcessPool method) archives (luigi.contrib.spark.SparkSubmitTask attribute) args() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) (luigi.contrib.hadoop_jar.HadoopJarJobTask method) (luigi.contrib.scalding.ScaldingJobTask method) assistant (luigi.interface.core attribute) (luigi.scheduler.Worker attribute) AsyncCompletionException atomic_file (class in luigi.local_target) atomic_output() (luigi.contrib.hadoop_jar.HadoopJarJobTask method) (luigi.contrib.scalding.ScaldingJobTask method) AtomicFtpFile (class in luigi.contrib.ftp) AtomicGCSFile (class in luigi.contrib.gcs) AtomicLocalFile (class in luigi.target) AtomicRemoteFileWriter (class in luigi.contrib.ssh) AtomicS3File (class in luigi.contrib.s3) AtomicWebHdfsFile (class in luigi.contrib.webhdfs) AtomicWritableDropboxFile (class in luigi.contrib.dropbox) attach() (in module luigi.contrib.hadoop) auth_file_path (luigi.contrib.pai.PaiTask attribute) auth_method (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask attribute) authFile (luigi.contrib.pai.PaiJob attribute) auto_namespace() (in module luigi) (in module luigi.task) auto_remove (luigi.contrib.docker_runner.DockerTask attribute) autocommit (luigi.contrib.rdbms.Query attribute) autoscaling_algorithm (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) AVRO (luigi.contrib.bigquery.DestinationFormat attribute) (luigi.contrib.bigquery.SourceFormat attribute)

B

backoff_limit (luigi.contrib.kubernetes.KubernetesJobTask attribute) BaseHadoopJobTask (class in luigi.contrib.hadoop) BaseLogging (class in luigi.setup_logging) BaseParser (class in luigi.configuration.base_parser) BaseTaskHistoryHandler (class in luigi.server) BaseWrapper (class in luigi.format) BATCH (luigi.contrib.bigquery.QueryMode attribute) batch_counter_default (luigi.contrib.hadoop.BaseHadoopJobTask attribute) batch_email (class in luigi.batch_notifier) batch_emails (luigi.scheduler.scheduler attribute) batch_mode (luigi.batch_notifier.batch_email attribute) batch_param_names() (luigi.Task class method) (luigi.task.Task class method) batchable (luigi.Task attribute) (luigi.task.Task attribute) BatchClient (class in luigi.contrib.batch) BatchJobException BatchNotifier (class in luigi.batch_notifier) BatchTask (class in luigi.contrib.batch) bcolors (class in luigi.tools.deps_tree) BeamDataflowJobTask (class in luigi.contrib.beam_dataflow) before_get() (luigi.configuration.cfg_parser.CombinedInterpolation method) (luigi.configuration.cfg_parser.EnvironmentInterpolation method) before_read() (luigi.configuration.cfg_parser.CombinedInterpolation method) before_run() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) before_set() (luigi.configuration.cfg_parser.CombinedInterpolation method) before_write() (luigi.configuration.cfg_parser.CombinedInterpolation method) beginAt (luigi.contrib.pai.Port attribute) BigQueryClient (class in luigi.contrib.bigquery) BigqueryClient (in module luigi.contrib.bigquery) BigQueryCreateViewTask (class in luigi.contrib.bigquery)

BigqueryCreateViewTask (in module luigi.contrib.bigquery) BigQueryExtractTask (class in luigi.contrib.bigquery) BigQueryLoadAvro (class in luigi.contrib.bigquery_avro) BigQueryLoadTask (class in luigi.contrib.bigquery) BigqueryLoadTask (in module luigi.contrib.bigquery) BigQueryRunQueryTask (class in luigi.contrib.bigquery) BigqueryRunQueryTask (in module luigi.contrib.bigquery) BigQueryTarget (class in luigi.contrib.bigquery) BigqueryTarget (in module luigi.contrib.bigquery) binds (luigi.contrib.docker_runner.DockerTask attribute) block_on_batch() (luigi.contrib.salesforce.SalesforceAPI method) BoolParameter (class in luigi) (class in luigi.parameter) BQDataset (class in luigi.contrib.bigquery) BQTable (class in luigi.contrib.bigquery) BROKEN_TASK (luigi.Event attribute) (luigi.event.Event attribute) build() (in module luigi) (in module luigi.interface) build_job_jar() (luigi.contrib.scalding.ScaldingJobRunner method) build_tracking_url() (luigi.contrib.external_program.ExternalProgramTask method) bulk_complete() (luigi.contrib.bigquery.MixinBigQueryBulkComplete class method) (luigi.Task class method) (luigi.task.MixinNaiveBulkComplete class method) (luigi.task.Task class method) bulk_size (luigi.contrib.mysqldb.CopyToTable attribute) BulkCompleteNotImplementedError ByIdHandler (class in luigi.server) ByNameHandler (class in luigi.server) ByParamsHandler (class in luigi.server) bytes_per_reducer (luigi.contrib.hive.HiveQueryTask attribute) Bzip2Format (class in luigi.format)

C

call_check() (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient static method) capture_output (luigi.contrib.external_program.ExternalProgramTask attribute) CascadingClient (class in luigi.contrib.target) catalog (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask attribute) ChainFormat (class in luigi.format) check_complete() (in module luigi.worker) check_complete_on_run (luigi.worker.worker attribute) check_output() (luigi.contrib.ssh.RemoteContext method) check_pid() (in module luigi.process) (luigi.rpc.RequestsFetcher method) check_unfulfilled_deps (luigi.worker.worker attribute) chmod() (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) ChoiceParameter (class in luigi) (class in luigi.parameter) chown() (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) chunk_size (luigi.contrib.esindex.CopyToIndex attribute) (luigi.contrib.sqla.CopyToTable attribute) cleanup_on_error() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) clear() (luigi.mock.MockFileSystem method) (luigi.scheduler.Failures method) clear_instance_cache() (luigi.task_register.Register class method) client (luigi.contrib.hdfs.config.hdfs attribute) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient attribute) client_type (luigi.contrib.hdfs.webhdfs_client.webhdfs attribute) client_version (luigi.contrib.hdfs.config.hdfs attribute) clone() (luigi.Task method) (luigi.task.Task method) close() (luigi.contrib.dropbox.ReadableDropboxFile method) (luigi.contrib.hdfs.format.HdfsAtomicWriteDirPipe method) (luigi.contrib.hdfs.format.HdfsAtomicWritePipe method) (luigi.contrib.s3.ReadableS3File method) (luigi.contrib.ssh.AtomicRemoteFileWriter method) (luigi.contrib.webhdfs.ReadableWebHdfsFile method) (luigi.format.InputPipeProcessWrapper method) (luigi.format.OutputPipeProcessWrapper method) (luigi.target.AtomicLocalFile method) (luigi.worker.SingleProcessPool method) close_job() (luigi.contrib.salesforce.SalesforceAPI method) cluster (luigi.contrib.ecs.ECSTask attribute) cmd_line_runner (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) CmdlineParser (class in luigi.cmdline_parser) code_dir (luigi.contrib.pai.PaiTask attribute) codeDir (luigi.contrib.pai.PaiJob attribute) column_separator (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.sqla.CopyToTable attribute) columns (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.sqla.CopyToTable attribute) CombinedInterpolation (class in luigi.configuration.cfg_parser) combiner (luigi.contrib.hadoop.JobTask attribute) COMMA (luigi.contrib.bigquery.FieldDelimiter attribute) command (luigi.contrib.docker_runner.DockerTask attribute) (luigi.contrib.ecs.ECSTask attribute) (luigi.contrib.hdfs.config.hadoopcli attribute) (luigi.contrib.pai.TaskRole attribute) common_params() (in module luigi.util) CompatibleHdfsFormat (class in luigi.contrib.hdfs.format) complete() (luigi.contrib.bigquery.BigQueryCreateViewTask method) (luigi.Task method) (luigi.WrapperTask method) (luigi.contrib.dataproc.CreateDataprocClusterTask method) (luigi.contrib.dataproc.DeleteDataprocClusterTask method) (luigi.contrib.pai.PaiTask method) (luigi.notifications.TestNotificationsTask method) (luigi.task.Task method) (luigi.task.WrapperTask method) COMPLETE_COUNT (luigi.tools.range.RangeEvent attribute) COMPLETE_FRACTION (luigi.tools.range.RangeEvent attribute) Compression (class in luigi.contrib.bigquery) compression (luigi.contrib.bigquery.BigQueryExtractTask attribute) conf (luigi.contrib.spark.SparkSubmitTask attribute) Config (class in luigi) (class in luigi.task)

config (luigi.setup_logging.BaseLogging attribute) configure_http_handler() (luigi.metrics.MetricsCollector method) conform_query() (luigi.contrib.opener.Opener class method) connect() (luigi.contrib.mssqldb.MSSqlTarget method) (luigi.contrib.mysqldb.MySqlTarget method) (luigi.contrib.postgres.PostgresTarget method) connect_args (luigi.contrib.sqla.CopyToTable attribute) connection_reset_wait_seconds (luigi.contrib.redshift.KillOpenRedshiftSessions attribute) connection_string (luigi.contrib.sqla.CopyToTable attribute) container_options (luigi.contrib.docker_runner.DockerTask attribute) container_tmp_dir (luigi.contrib.docker_runner.DockerTask attribute) content_type (luigi.contrib.salesforce.QuerySalesforce attribute) ContextManagedTaskProcess (class in luigi.worker) copies (class in luigi.util) copy() (luigi.contrib.bigquery.BigQueryClient method) (luigi.LocalTarget method) (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.mysqldb.CopyToTable method) (luigi.contrib.postgres.CopyToTable method) (luigi.contrib.rdbms.CopyToTable method) (luigi.contrib.redshift.S3CopyJSONToTable method) (luigi.contrib.redshift.S3CopyToTable method) (luigi.contrib.s3.S3Client method) (luigi.contrib.sqla.CopyToTable method) (luigi.local_target.LocalFileSystem method) (luigi.local_target.LocalTarget method) (luigi.mock.MockFileSystem method) (luigi.target.FileSystem method) copy_json_options (luigi.contrib.redshift.S3CopyJSONToTable attribute) copy_options (luigi.contrib.redshift.S3CopyToTable attribute) CopyToIndex (class in luigi.contrib.esindex) CopyToTable (class in luigi.contrib.mysqldb) (class in luigi.contrib.postgres) (class in luigi.contrib.rdbms) (class in luigi.contrib.sqla) core (class in luigi.interface) cors (class in luigi.server) count() (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.presto.PrestoTarget method) count_last_scheduled (luigi.worker.worker attribute) count_pending() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) count_uniques (luigi.worker.worker attribute) cpuNumber (luigi.contrib.pai.TaskRole attribute) create_batch() (luigi.contrib.salesforce.SalesforceAPI method) create_disposition (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) create_hadoopcli_client() (in module luigi.contrib.hdfs.hadoopcli_clients) CREATE_IF_NEEDED (luigi.contrib.bigquery.CreateDisposition attribute) create_index() (luigi.contrib.esindex.CopyToIndex method) create_marker_index() (luigi.contrib.esindex.ElasticsearchTarget method) create_marker_table() (luigi.contrib.mssqldb.MSSqlTarget method) (luigi.contrib.mysqldb.MySqlTarget method) (luigi.contrib.postgres.PostgresTarget method) (luigi.contrib.sqla.SQLAlchemyTarget method) CREATE_NEVER (luigi.contrib.bigquery.CreateDisposition attribute) create_operation_job() (luigi.contrib.salesforce.SalesforceAPI method) create_packages_archive() (in module luigi.contrib.hadoop) create_schema() (luigi.contrib.redshift.S3CopyToTable method) create_subprocess() (luigi.format.InputPipeProcessWrapper method) create_table() (luigi.contrib.rdbms.CopyToTable method) (luigi.contrib.redshift.S3CopyToTable method) (luigi.contrib.sqla.CopyToTable method) CreateDataprocClusterTask (class in luigi.contrib.dataproc) CreateDisposition (class in luigi.contrib.bigquery) CSV (luigi.contrib.bigquery.DestinationFormat attribute) (luigi.contrib.bigquery.SourceFormat attribute) CURRENT_SOURCE_VERSION (luigi.db_task_history.DbTaskHistory attribute) Custom (class in luigi.date_interval)

D

daemonize() (in module luigi.process) DaemonLogging (class in luigi.setup_logging) data (luigi.configuration.LuigiTomlParser attribute) (luigi.configuration.toml_parser.LuigiTomlParser attribute) data_dir (luigi.contrib.pai.PaiTask attribute) data_interchange_format (luigi.contrib.hadoop.BaseHadoopJobTask attribute) database (luigi.contrib.hive.ExternalHiveTask attribute) (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.contrib.redshift.KillOpenRedshiftSessions attribute) dataDir (luigi.contrib.pai.PaiJob attribute) datadog (class in luigi.contrib.datadog_metric) (luigi.metrics.MetricsCollectors attribute) DatadogMetricsCollector (class in luigi.contrib.datadog_metric) dataflow_executable() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) dataflow_params (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) DataflowParamKeys (class in luigi.contrib.beam_dataflow) DataprocBaseTask (class in luigi.contrib.dataproc) DataprocPysparkTask (class in luigi.contrib.dataproc) DataprocSparkTask (class in luigi.contrib.dataproc) dataset (luigi.contrib.bigquery.BQTable attribute) dataset_exists() (luigi.contrib.bigquery.BigQueryClient method) dataset_id (luigi.contrib.bigquery.BQDataset attribute) DATASTORE_BACKUP (luigi.contrib.bigquery.SourceFormat attribute) Date (class in luigi.date_interval) date (luigi.contrib.external_daily_snapshot.ExternalDailySnapshot attribute) date_format (luigi.DateHourParameter attribute) (luigi.DateMinuteParameter attribute) (luigi.DateParameter attribute) (luigi.DateSecondParameter attribute) (luigi.MonthParameter attribute) (luigi.YearParameter attribute) (luigi.parameter.DateHourParameter attribute) (luigi.parameter.DateMinuteParameter attribute) (luigi.parameter.DateParameter attribute) (luigi.parameter.DateSecondParameter attribute) (luigi.parameter.MonthParameter attribute) (luigi.parameter.YearParameter attribute) DateHourParameter (class in luigi) (class in luigi.parameter) DateInterval (class in luigi.date_interval) DateIntervalParameter (class in luigi) (class in luigi.parameter) DateMinuteParameter (class in luigi) (class in luigi.parameter) DateParameter (class in luigi) (class in luigi.parameter) dates() (luigi.date_interval.DateInterval method) DateSecondParameter (class in luigi) (class in luigi.parameter) datetime_to_parameter() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method) datetime_to_parameters() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method) days_back (luigi.tools.range.RangeDailyBase attribute) days_forward (luigi.tools.range.RangeDailyBase attribute) DbTaskHistory (class in luigi.db_task_history) decrease_running_resources() (luigi.worker.TaskStatusReporter method) decrease_running_task_resources() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) default (luigi.metrics.MetricsCollectors attribute) DEFAULT_DB_PORT (luigi.contrib.postgres.PostgresTarget attribute) (luigi.contrib.redshift.RedshiftTarget attribute) DEFAULT_PART_SIZE (luigi.contrib.s3.S3Client attribute) default_tags (luigi.contrib.datadog_metric.datadog attribute) (luigi.contrib.datadog_metric.DatadogMetricsCollector attribute) DEFAULT_THREADS (luigi.contrib.s3.S3Client attribute) DefaultHadoopJobRunner (class in luigi.contrib.hadoop)

DELAY (luigi.tools.range.RangeEvent attribute) delegates() (in module luigi.util) delete_dataset() (luigi.contrib.bigquery.BigQueryClient method) delete_index() (luigi.contrib.esindex.CopyToIndex method) delete_on_success (luigi.contrib.kubernetes.KubernetesJobTask attribute) delete_table() (luigi.contrib.bigquery.BigQueryClient method) DeleteDataprocClusterTask (class in luigi.contrib.dataproc) dep_graph() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) DEPENDENCY_DISCOVERED (luigi.Event attribute) (luigi.event.Event attribute) DEPENDENCY_MISSING (luigi.Event attribute) (luigi.event.Event attribute) DEPENDENCY_PRESENT (luigi.Event attribute) (luigi.event.Event attribute) deploy_mode (luigi.contrib.spark.SparkSubmitTask attribute) deprecated_date_format (luigi.DateMinuteParameter attribute) (luigi.parameter.DateMinuteParameter attribute) DeprecatedBotoClientException deps() (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.Task method) (luigi.task.Task method) DequeQueue (class in luigi.worker) dereference() (in module luigi.contrib.hadoop) destination_format (luigi.contrib.bigquery.BigQueryExtractTask attribute) destination_uris (luigi.contrib.bigquery.BigQueryExtractTask attribute) DestinationFormat (class in luigi.contrib.bigquery) dfs_paths() (in module luigi.tools.deps) DictParameter (class in luigi) (class in luigi.parameter) disable_hard_timeout (luigi.scheduler.RetryPolicy attribute) (luigi.Task attribute) (luigi.scheduler.scheduler attribute) (luigi.task.Task attribute) disable_instance_cache() (luigi.task_register.Register class method) disable_persist (luigi.scheduler.scheduler attribute) disable_window (luigi.scheduler.RetryPolicy attribute) (luigi.scheduler.scheduler attribute) disable_window_seconds (luigi.Task attribute) (luigi.task.Task attribute) disable_worker() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) disable_workers() (luigi.scheduler.SimpleTaskState method) disabled (luigi.Task attribute) (luigi.task.Task attribute) discard() (luigi.scheduler.OrderedSet method) disk_size_gb (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) dispatch_scheduler_message() (luigi.worker.Worker method) do_prune() (luigi.contrib.redshift.S3CopyToTable method) do_truncate_table (luigi.contrib.redshift.S3CopyToTable attribute) do_work_on_compute_node() (in module luigi.contrib.lsf_runner) doc_type (luigi.contrib.esindex.CopyToIndex attribute) docker_url (luigi.contrib.docker_runner.DockerTask attribute) DockerTask (class in luigi.contrib.docker_runner) docs() (luigi.contrib.esindex.CopyToIndex method) does_schema_exist() (luigi.contrib.redshift.S3CopyToTable method) does_table_exist() (luigi.contrib.redshift.S3CopyToTable method) done() (luigi.contrib.simulate.RunAnywayTarget method) dont_remove_tmp_dir (luigi.contrib.sge.SGEJobTask attribute) download() (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) download_as_bytes() (luigi.contrib.dropbox.DropboxClient method) driver_class_path (luigi.contrib.spark.SparkSubmitTask attribute) driver_cores (luigi.contrib.spark.SparkSubmitTask attribute) driver_java_options (luigi.contrib.spark.SparkSubmitTask attribute) driver_library_path (luigi.contrib.spark.SparkSubmitTask attribute) driver_memory (luigi.contrib.spark.SparkSubmitTask attribute) DropboxClient (class in luigi.contrib.dropbox) DropboxTarget (class in luigi.contrib.dropbox) dump() (luigi.contrib.hadoop.JobTask method) (luigi.scheduler.Scheduler method) (luigi.scheduler.SimpleTaskState method) DuplicateParameterException

E

echo (luigi.contrib.sqla.CopyToTable attribute) ecs_task_ids (luigi.contrib.ecs.ECSTask attribute) ECSTask (class in luigi.contrib.ecs) effective_user (luigi.contrib.hdfs.config.hdfs attribute) ElasticsearchTarget (class in luigi.contrib.esindex) email (class in luigi.notifications) email_interval (luigi.batch_notifier.batch_email attribute) enabled (luigi.configuration.cfg_parser.LuigiConfigParser attribute) (luigi.configuration.LuigiConfigParser attribute) (luigi.configuration.LuigiTomlParser attribute) (luigi.configuration.toml_parser.LuigiTomlParser attribute) (luigi.scheduler.Worker attribute) (luigi.server.cors attribute) Encoding (class in luigi.contrib.bigquery) encoding (luigi.contrib.bigquery.BigQueryLoadTask attribute) ENDC (luigi.tools.deps_tree.bcolors attribute) engine (luigi.contrib.sqla.SQLAlchemyTarget attribute) (luigi.contrib.sqla.SQLAlchemyTarget.Connection attribute) enqueue() (luigi.batch_notifier.ExplQueue method) ensure_hist_size() (luigi.contrib.esindex.ElasticsearchTarget method) ensure_utf() (in module luigi.contrib.salesforce) entry_class (luigi.contrib.spark.SparkSubmitTask attribute) EnumListParameter (class in luigi.parameter) EnumParameter (class in luigi) (class in luigi.parameter) environment (luigi.contrib.datadog_metric.datadog attribute) (luigi.contrib.docker_runner.DockerTask attribute) EnvironmentInterpolation (class in luigi.configuration.cfg_parser) error_lines (luigi.batch_notifier.batch_email attribute) error_messages (luigi.batch_notifier.batch_email attribute) Event (class in luigi) (class in luigi.event) event_handler() (luigi.Task class method) (luigi.task.Task class method) event_name (luigi.db_task_history.TaskEvent attribute) events (luigi.db_task_history.TaskRecord attribute) execute() (luigi.contrib.presto.PrestoClient method) execution_summary (class in luigi.execution_summary) executor_cores (luigi.contrib.spark.SparkSubmitTask attribute) executor_memory (luigi.contrib.spark.SparkSubmitTask attribute) exists() (in module luigi.contrib.hdfs.clients) (luigi.Target method) (luigi.contrib.bigquery.BigQueryTarget method) (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.esindex.ElasticsearchTarget method) (luigi.contrib.ftp.RemoteFileSystem method) (luigi.contrib.ftp.RemoteTarget method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.gcs.GCSFlagTarget method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClientApache1 method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.target.HdfsFlagTarget method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.hive.HivePartitionTarget method) (luigi.contrib.mongodb.MongoCellTarget method) (luigi.contrib.mongodb.MongoCollectionTarget method) (luigi.contrib.mongodb.MongoCountTarget method) (luigi.contrib.mongodb.MongoRangeTarget method) (luigi.contrib.mssqldb.MSSqlTarget method) (luigi.contrib.mysqldb.MySqlTarget method) (luigi.contrib.postgres.PostgresTarget method) (luigi.contrib.presto.PrestoTarget method) (luigi.contrib.redis_store.RedisTarget method) (luigi.contrib.s3.S3Client method) (luigi.contrib.s3.S3FlagTarget method) (luigi.contrib.simulate.RunAnywayTarget method) (luigi.contrib.sqla.SQLAlchemyTarget method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.local_target.LocalFileSystem method) (luigi.mock.MockFileSystem method) (luigi.mock.MockTarget method) (luigi.target.FileSystem method) (luigi.target.FileSystemTarget method) (luigi.target.Target method)

expiration (luigi.contrib.pai.OpenPai attribute) EXPLICIT_PARSING (luigi.BoolParameter attribute) (luigi.parameter.BoolParameter attribute) ExplQueue (class in luigi.batch_notifier) exposed_headers (luigi.server.cors attribute) ExternalBigQueryTask (class in luigi.contrib.bigquery) ExternalBigqueryTask (in module luigi.contrib.bigquery) ExternalDailySnapshot (class in luigi.contrib.external_daily_snapshot) ExternalHiveTask (class in luigi.contrib.hive) externalize() (in module luigi.task) ExternalProgramRunContext (class in luigi.contrib.external_program) ExternalProgramRunError ExternalProgramTask (class in luigi.contrib.external_program) ExternalPythonProgramTask (class in luigi.contrib.external_program) ExternalTask (class in luigi) (class in luigi.task) extra_archives() (luigi.contrib.hadoop.JobTask method) extra_bsub_args (luigi.contrib.lsf.LSFJobTask attribute) extra_elasticsearch_args (luigi.contrib.esindex.CopyToIndex attribute) extra_files (luigi.contrib.dataproc.DataprocPysparkTask attribute) extra_files() (luigi.contrib.hadoop.JobTask method) extra_jars() (luigi.contrib.scalding.ScaldingJobTask method) extra_modules() (luigi.contrib.hadoop.JobTask method) extra_pythonpath (luigi.contrib.external_program.ExternalPythonProgramTask attribute) extra_streaming_arguments() (luigi.contrib.hadoop.JobTask method) extract_packages_archive() (in module luigi.contrib.lsf_runner) (luigi.contrib.mrrunner.Runner method)

F

fail_dead_worker_task() (luigi.scheduler.SimpleTaskState method) FAILED (luigi.execution_summary.LuigiStatusCode attribute) (luigi.LuigiStatusCode attribute) FAILED_AND_SCHEDULING_FAILED (luigi.execution_summary.LuigiStatusCode attribute) (luigi.LuigiStatusCode attribute) FAILURE (luigi.Event attribute) (luigi.event.Event attribute) Failures (class in luigi.scheduler) FALSE (luigi.contrib.bigquery.PrintHeader attribute) family (luigi.tools.deps.upstream attribute) fetch() (luigi.rpc.RequestsFetcher method) (luigi.rpc.URLLibFetcher method) fetch_error() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) fetch_rpc_messages() (luigi.scheduler.Worker method) fetch_task_failures() (in module luigi.contrib.hadoop) (luigi.contrib.lsf.LSFJobTask method) fetch_task_output() (luigi.contrib.lsf.LSFJobTask method) field_delimiter (luigi.contrib.bigquery.BigQueryExtractTask attribute) (luigi.contrib.bigquery.BigQueryLoadTask attribute) FieldDelimiter (class in luigi.contrib.bigquery) file_pattern() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) FileAlreadyExists FileNotFoundException files (luigi.contrib.spark.PySparkTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) FileSystem (class in luigi.target) FileSystemException FileSystemTarget (class in luigi.target) FileWrapper (class in luigi.format) filter_kwargs (luigi.contrib.opener.Opener attribute) (luigi.contrib.opener.S3Opener attribute) final_combiner (luigi.contrib.hadoop.BaseHadoopJobTask attribute) final_mapper (luigi.contrib.hadoop.BaseHadoopJobTask attribute) final_reducer (luigi.contrib.hadoop.BaseHadoopJobTask attribute) find_all_by_name() (luigi.db_task_history.DbTaskHistory method) find_all_by_parameters() (luigi.db_task_history.DbTaskHistory method) find_all_events() (luigi.db_task_history.DbTaskHistory method) find_all_runs() (luigi.db_task_history.DbTaskHistory method) find_deps() (in module luigi.tools.deps) find_deps_cli() (in module luigi.tools.deps) find_latest_runs() (luigi.db_task_history.DbTaskHistory method) find_task_by_id() (luigi.db_task_history.DbTaskHistory method) finish() (luigi.contrib.hadoop.HadoopJobRunner method) finite_datetimes() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method)

fix_paths() (in module luigi.contrib.hadoop_jar) flag (luigi.contrib.s3.S3FlagTask attribute) flatten() (in module luigi.contrib.hadoop) (in module luigi.task) flatten_output() (in module luigi.task) flatten_results (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) FloatParameter (class in luigi) (class in luigi.parameter) fn (luigi.local_target.LocalTarget attribute) (luigi.LocalTarget attribute) folder_paths (luigi.contrib.redshift.RedshiftManifestTask attribute) force_multiprocessing (luigi.worker.worker attribute) force_pull (luigi.contrib.docker_runner.DockerTask attribute) force_send (luigi.notifications.email attribute) forgive_failures() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) Format (class in luigi.format) format (luigi.notifications.email attribute) format_task_error() (in module luigi.notifications) forward_reporter_attributes (luigi.worker.TaskProcess attribute) from_bqtable() (luigi.contrib.bigquery.BigQueryTarget class method) from_date() (luigi.date_interval.Date class method) (luigi.date_interval.DateInterval class method) (luigi.date_interval.Month class method) (luigi.date_interval.Week class method) (luigi.date_interval.Year class method) from_str_params() (luigi.Task class method) (luigi.task.Task class method) from_utc() (in module luigi.server) FrozenOrderedDict (class in luigi.freezing) fs (luigi.contrib.dropbox.DropboxTarget attribute) (luigi.LocalTarget attribute) (luigi.contrib.ftp.AtomicFtpFile attribute) (luigi.contrib.ftp.RemoteTarget attribute) (luigi.contrib.gcs.GCSFlagTarget attribute) (luigi.contrib.gcs.GCSTarget attribute) (luigi.contrib.hdfs.target.HdfsTarget attribute) (luigi.contrib.s3.S3FlagTarget attribute) (luigi.contrib.s3.S3Target attribute) (luigi.contrib.ssh.AtomicRemoteFileWriter attribute) (luigi.contrib.ssh.RemoteTarget attribute) (luigi.contrib.webhdfs.WebHdfsTarget attribute) (luigi.local_target.LocalTarget attribute) (luigi.mock.MockTarget attribute) (luigi.target.FileSystemTarget attribute)

G

gcloud_network (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) gcloud_zone (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) gcp_temp_location (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) GCSClient (class in luigi.contrib.gcs) GCSFlagTarget (class in luigi.contrib.gcs) GCSTarget (class in luigi.contrib.gcs) generate_email() (in module luigi.notifications) generate_latest() (luigi.metrics.MetricsCollector method) generate_tmp_path() (luigi.local_target.atomic_file method) (luigi.target.AtomicLocalFile method) get (luigi.metrics.MetricsCollectors attribute) get() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) (luigi.contrib.ftp.RemoteFileSystem method) (luigi.contrib.ftp.RemoteTarget method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.contrib.ssh.RemoteTarget method) (luigi.server.AllRunHandler method) (luigi.server.ByIdHandler method) (luigi.server.ByNameHandler method) (luigi.server.ByParamsHandler method) (luigi.server.MetricsHandler method) (luigi.server.RPCHandler method) (luigi.server.RecentRunHandler method) (luigi.server.RootPathHandler method) (luigi.server.SelectedRunHandler method) (luigi.worker.DequeQueue method) get_active_queue() (luigi.contrib.batch.BatchClient method) get_active_task_count_for_status() (luigi.scheduler.SimpleTaskState method) get_active_tasks() (luigi.scheduler.SimpleTaskState method) get_active_tasks_by_status() (luigi.scheduler.SimpleTaskState method) get_active_workers() (luigi.scheduler.SimpleTaskState method) get_all_data() (luigi.mock.MockFileSystem method) get_all_params() (luigi.task_register.Register class method) get_arglist() (luigi.contrib.hive.HiveQueryRunner method) get_as_bytes() (luigi.contrib.s3.S3Client method) get_as_string() (luigi.contrib.s3.S3Client method) get_assistants() (luigi.scheduler.SimpleTaskState method) get_authenticate_kwargs() (in module luigi.contrib.gcp) get_autoconfig_client() (in module luigi.contrib.hdfs.clients) get_batch_result() (luigi.contrib.salesforce.SalesforceAPI method) get_batch_result_ids() (luigi.contrib.salesforce.SalesforceAPI method) get_batch_results() (luigi.contrib.salesforce.SalesforceAPI method) get_batch_running_tasks() (luigi.scheduler.SimpleTaskState method) get_batcher() (luigi.scheduler.SimpleTaskState method) get_bite() (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) get_build_dir() (luigi.contrib.scalding.ScaldingJobRunner method) get_collection() (luigi.contrib.mongodb.MongoTarget method) get_config() (in module luigi.configuration) (in module luigi.configuration.core) get_configured_hadoop_version() (in module luigi.contrib.hdfs.config) get_configured_hdfs_client() (in module luigi.contrib.hdfs.config) get_data() (luigi.mock.MockFileSystem method) get_dataproc_client() (in module luigi.contrib.dataproc) get_default_client() (in module luigi.contrib.hive) get_default_format() (in module luigi.format) get_empty_ids() (luigi.contrib.mongodb.MongoRangeTarget method) get_environment() (luigi.contrib.spark.SparkSubmitTask method) get_extra_files() (in module luigi.contrib.hadoop) get_hive_syntax() (in module luigi.contrib.hive) get_hive_warehouse_location() (in module luigi.contrib.hive) get_ignored_file_masks() (in module luigi.contrib.hive) get_index() (luigi.contrib.mongodb.MongoTarget method) get_info() (in module luigi.lock) get_instance() (luigi.cmdline_parser.CmdlineParser class method) get_job_class() (luigi.contrib.scalding.ScaldingJobRunner method) get_job_details() (luigi.contrib.salesforce.SalesforceAPI method) get_job_id_from_name() (luigi.contrib.batch.BatchClient method) get_job_status() (luigi.contrib.batch.BatchClient method) get_key() (luigi.contrib.s3.S3Client method) get_libjars() (luigi.contrib.scalding.ScaldingJobRunner method) get_log_format() (in module luigi.process) get_logs() (luigi.contrib.batch.BatchClient method) get_merge() (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) get_opener() (luigi.contrib.opener.OpenerRegistry method)

get_param_names() (luigi.Task class method) (luigi.task.Task class method) get_param_values() (luigi.Task class method) (luigi.task.Task class method) get_params() (luigi.Task class method) (luigi.task.Task class method) get_path() (luigi.contrib.simulate.RunAnywayTarget method) get_previous_completed() (in module luigi.util) get_provided_jars() (luigi.contrib.scalding.ScaldingJobRunner method) get_running_task_resources() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) get_scala_jars() (luigi.contrib.scalding.ScaldingJobRunner method) get_scalding_core() (luigi.contrib.scalding.ScaldingJobRunner method) get_scalding_jars() (luigi.contrib.scalding.ScaldingJobRunner method) get_scheduler_message_response() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) get_soql_fields() (in module luigi.contrib.salesforce) get_spool_handler() (in module luigi.process) get_state() (luigi.scheduler.SimpleTaskState method) get_target() (luigi.contrib.opener.LocalOpener class method) (luigi.contrib.opener.MockOpener class method) (luigi.contrib.opener.Opener class method) (luigi.contrib.opener.S3Opener class method) get_target_path() (luigi.contrib.beam_dataflow.BeamDataflowJobTask static method) get_task() (luigi.scheduler.SimpleTaskState method) get_task_cls() (luigi.task_register.Register class method) get_task_family() (luigi.Task class method) (luigi.task.Task class method) get_task_namespace() (luigi.Task class method) (luigi.task.Task class method) get_task_obj() (luigi.cmdline_parser.CmdlineParser method) get_task_output_description() (in module luigi.tools.deps) get_task_progress_percentage() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) get_task_requires() (in module luigi.tools.deps) get_task_status_message() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) get_tasks() (luigi.scheduler.Worker method) get_template_path() (luigi.server.BaseTaskHistoryHandler method) get_tmp_job_jar() (luigi.contrib.scalding.ScaldingJobRunner method) get_view() (luigi.contrib.bigquery.BigQueryClient method) get_work() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) get_worker() (luigi.scheduler.SimpleTaskState method) get_worker_ids() (luigi.scheduler.SimpleTaskState method) get_wrapped() (luigi.freezing.FrozenOrderedDict method) getboolean() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) getfloat() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) getint() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) getintdict() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) getmerge() (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) getpaths() (in module luigi.task) getpcmd() (in module luigi.lock) GetWorkResponse (class in luigi.worker) glob_exists() (luigi.contrib.hdfs.target.HdfsTarget method) global_instance() (luigi.cmdline_parser.CmdlineParser class method) gpu_type (luigi.contrib.pai.PaiTask attribute) gpuNumber (luigi.contrib.pai.TaskRole attribute) gpuType (luigi.contrib.pai.PaiJob attribute) graph() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) graph_url (luigi.tools.luigi_grep.LuigiGrep attribute) group() (luigi.contrib.hadoop.LocalJobRunner method) group_by_error_messages (luigi.batch_notifier.batch_email attribute) GZIP (luigi.contrib.bigquery.Compression attribute) GzipFormat (class in luigi.format)

H

hadoop (class in luigi.contrib.hadoop) hadoop_conf_dir (luigi.contrib.spark.SparkSubmitTask attribute) hadoop_user_name (luigi.contrib.spark.SparkSubmitTask attribute) hadoopcli (class in luigi.contrib.hdfs.config) HadoopJarJobError HadoopJarJobRunner (class in luigi.contrib.hadoop_jar) HadoopJarJobTask (class in luigi.contrib.hadoop_jar) HadoopJobError HadoopJobRunner (class in luigi.contrib.hadoop) HadoopRunContext (class in luigi.contrib.hadoop) handle_interrupt() (luigi.worker.Worker method) handle_task_disabled() (luigi.contrib.datadog_metric.DatadogMetricsCollector method) (luigi.metrics.MetricsCollector method) (luigi.metrics.NoMetricsCollector method) handle_task_done() (luigi.contrib.datadog_metric.DatadogMetricsCollector method) (luigi.metrics.MetricsCollector method) (luigi.metrics.NoMetricsCollector method) handle_task_failed() (luigi.contrib.datadog_metric.DatadogMetricsCollector method) (luigi.metrics.MetricsCollector method) (luigi.metrics.NoMetricsCollector method) handle_task_started() (luigi.contrib.datadog_metric.DatadogMetricsCollector method) (luigi.metrics.MetricsCollector method) (luigi.metrics.NoMetricsCollector method) has_active_session() (luigi.contrib.salesforce.SalesforceAPI method) has_excessive_failures() (luigi.scheduler.Task method) has_option() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) has_task() (luigi.scheduler.SimpleTaskState method) has_task_history() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) has_task_value() (luigi.Parameter method) (luigi.parameter.Parameter method) has_value (luigi.parameter.ParameterVisibility attribute) hdfs (class in luigi.contrib.hdfs.config) hdfs_reader() (luigi.contrib.hdfs.format.CompatibleHdfsFormat method) (luigi.contrib.hdfs.format.PlainDirFormat method) (luigi.contrib.hdfs.format.PlainFormat method)

hdfs_writer() (luigi.contrib.hdfs.format.CompatibleHdfsFormat method) (luigi.contrib.hdfs.format.PlainDirFormat method) (luigi.contrib.hdfs.format.PlainFormat method) HdfsAtomicWriteDirPipe (class in luigi.contrib.hdfs.format) HdfsAtomicWriteError HdfsAtomicWritePipe (class in luigi.contrib.hdfs.format) HdfsClient (class in luigi.contrib.hdfs.hadoopcli_clients) HdfsClientApache1 (class in luigi.contrib.hdfs.hadoopcli_clients) HdfsClientCdh3 (class in luigi.contrib.hdfs.hadoopcli_clients) HDFSCliError HdfsFileSystem (class in luigi.contrib.hdfs.abstract_client) HdfsFlagTarget (class in luigi.contrib.hdfs.target) HdfsReadPipe (class in luigi.contrib.hdfs.format) HdfsTarget (class in luigi.contrib.hdfs.target) head() (luigi.server.RootPathHandler method) help (luigi.interface.core attribute) help_all (luigi.interface.core attribute) HIDDEN (luigi.parameter.ParameterVisibility attribute) HiveClient (class in luigi.contrib.hive) HiveCommandClient (class in luigi.contrib.hive) HiveCommandError hiveconfs() (luigi.contrib.hive.HiveQueryTask method) HivePartitionTarget (class in luigi.contrib.hive) HiveQueryRunner (class in luigi.contrib.hive) HiveQueryTask (class in luigi.contrib.hive) hiverc() (luigi.contrib.hive.HiveQueryTask method) HiveTableTarget (class in luigi.contrib.hive) HiveThriftContext (class in luigi.contrib.hive) hivevars() (luigi.contrib.hive.HiveQueryTask method) host (luigi.contrib.esindex.CopyToIndex attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.presto.presto attribute) (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.contrib.redshift.KillOpenRedshiftSessions attribute) (luigi.db_task_history.TaskRecord attribute) (luigi.notifications.smtp attribute) hours() (luigi.date_interval.DateInterval method) hours_back (luigi.tools.range.RangeHourlyBase attribute) hours_forward (luigi.tools.range.RangeHourlyBase attribute) http_auth (luigi.contrib.esindex.CopyToIndex attribute)

I

id (luigi.db_task_history.TaskEvent attribute) (luigi.db_task_history.TaskRecord attribute) (luigi.worker.worker attribute) ignore_unknown_values (luigi.contrib.bigquery.BigQueryLoadTask attribute) image (luigi.contrib.docker_runner.DockerTask attribute) (luigi.contrib.pai.PaiJob attribute) (luigi.contrib.pai.PaiTask attribute) image_version (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) IMPLICIT_PARSING (luigi.BoolParameter attribute) (luigi.parameter.BoolParameter attribute) inactivate_tasks() (luigi.scheduler.SimpleTaskState method) inactivate_workers() (luigi.scheduler.SimpleTaskState method) incr_counter() (luigi.contrib.hadoop.JobTask method) index (luigi.contrib.esindex.CopyToIndex attribute) infer_bulk_complete_from_fs() (in module luigi.tools.range) info_uri (luigi.contrib.presto.PrestoClient attribute) inherits (class in luigi.util) init_combiner() (luigi.contrib.hadoop.JobTask method) init_copy() (luigi.contrib.rdbms.CopyToTable method) (luigi.contrib.redshift.S3CopyToTable method) init_hadoop() (luigi.contrib.hadoop.BaseHadoopJobTask method) init_local() (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.contrib.lsf.LSFJobTask method) init_mapper() (luigi.contrib.hadoop.JobTask method) init_reducer() (luigi.contrib.hadoop.JobTask method) initialize() (luigi.server.BaseTaskHistoryHandler method) (luigi.server.MetricsHandler method) (luigi.server.RPCHandler method) initialized() (luigi.Task method) (luigi.task.Task method) input (luigi.contrib.hdfs.format.PlainDirFormat attribute) (luigi.contrib.hdfs.format.PlainFormat attribute) (luigi.format.Bzip2Format attribute) (luigi.format.GzipFormat attribute) (luigi.format.NewlineFormat attribute) (luigi.format.TextFormat attribute)

input() (luigi.Task method) (luigi.task.Task method) input_hadoop() (luigi.contrib.hadoop.BaseHadoopJobTask method) input_local() (luigi.contrib.hadoop.BaseHadoopJobTask method) InputPipeProcessWrapper (class in luigi.format) instance() (luigi.configuration.base_parser.BaseParser class method) INTERACTIVE (luigi.contrib.bigquery.QueryMode attribute) InterfaceLogging (class in luigi.setup_logging) internal_reader() (luigi.contrib.hadoop.JobTask method) internal_writer() (luigi.contrib.hadoop.JobTask method) InterpolationMissingEnvvarError IntParameter (class in luigi) (class in luigi.parameter) InvalidDeleteException, [1] InvalidQuery inverse_dep_graph() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) is_batchable() (luigi.scheduler.Task method) is_dir() (luigi.contrib.s3.S3Client method) is_pause_enabled() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) is_paused() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) is_soql_file (luigi.contrib.salesforce.QuerySalesforce attribute) is_trivial_worker() (luigi.scheduler.Worker method) is_writable() (luigi.contrib.hdfs.target.HdfsTarget method) isdir() (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.local_target.LocalFileSystem method) (luigi.mock.MockFileSystem method) (luigi.target.FileSystem method) ISO_8859_1 (luigi.contrib.bigquery.Encoding attribute)

J

jar() (luigi.contrib.hadoop_jar.HadoopJarJobTask method) (luigi.contrib.scalding.ScaldingJobTask method) jars (luigi.contrib.dataproc.DataprocSparkTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) job_args (luigi.contrib.dataproc.DataprocPysparkTask attribute) (luigi.contrib.dataproc.DataprocSparkTask attribute) job_args() (luigi.contrib.scalding.ScaldingJobTask method) job_class() (luigi.contrib.scalding.ScaldingJobTask method) job_definition (luigi.contrib.batch.BatchTask attribute) job_file (luigi.contrib.dataproc.DataprocPysparkTask attribute) job_name (luigi.contrib.batch.BatchTask attribute) (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) (luigi.contrib.sge.SGEJobTask attribute) job_name_flag (luigi.contrib.lsf.LSFJobTask attribute)

job_name_format (luigi.contrib.sge.SGEJobTask attribute) job_queue (luigi.contrib.batch.BatchTask attribute) job_runner() (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.contrib.hadoop.JobTask method) (luigi.contrib.hadoop_jar.HadoopJarJobTask method) (luigi.contrib.hive.HiveQueryTask method) (luigi.contrib.scalding.ScaldingJobTask method) job_status (luigi.contrib.lsf.LSFJobTask attribute) jobconf_truncate (luigi.contrib.hadoop.JobTask attribute) jobconfs() (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.contrib.hadoop.JobTask method) jobName (luigi.contrib.pai.PaiJob attribute) JobRunner (class in luigi.contrib.hadoop) JobTask (class in luigi.contrib.hadoop) join() (luigi.worker.SingleProcessPool method) jsonpath (luigi.contrib.redshift.S3CopyJSONToTable attribute)

K

keep_alive (luigi.worker.worker attribute) KeepAliveThread (class in luigi.worker) kill_job() (in module luigi.contrib.lsf) (luigi.contrib.external_program.ExternalProgramRunContext method) (luigi.contrib.hadoop.HadoopRunContext method) (luigi.contrib.pig.PigRunContext method) KillOpenRedshiftSessions (class in luigi.contrib.redshift)

kubeconfig_path (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask attribute) kubernetes (class in luigi.contrib.kubernetes) kubernetes_config (luigi.contrib.kubernetes.KubernetesJobTask attribute) kubernetes_namespace (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask attribute) KubernetesJobTask (class in luigi.contrib.kubernetes)

L

label (luigi.contrib.pai.Port attribute) labels (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) (luigi.contrib.kubernetes.KubernetesJobTask attribute) latest() (luigi.contrib.external_daily_snapshot.ExternalDailySnapshot class method) list() (luigi.contrib.s3.S3Client method) list_datasets() (luigi.contrib.bigquery.BigQueryClient method) list_path() (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient static method) list_tables() (luigi.contrib.bigquery.BigQueryClient method) list_wildcard() (luigi.contrib.gcs.GCSClient method) listdir() (in module luigi.contrib.hdfs.clients) (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.ftp.RemoteFileSystem method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.local_target.LocalFileSystem method) (luigi.mock.MockFileSystem method) (luigi.target.FileSystem method) ListParameter (class in luigi) (class in luigi.parameter) load() (luigi.scheduler.Scheduler method) (luigi.scheduler.SimpleTaskState method) load_hadoop_cmd() (in module luigi.contrib.hdfs.config) load_hive_cmd() (in module luigi.contrib.hive) load_task() (in module luigi.task_register) local_hostname (luigi.notifications.smtp attribute) local_scheduler (luigi.interface.core attribute) LocalFileSystem (class in luigi.local_target) LocalJobRunner (class in luigi.contrib.hadoop) LocalLSFJobTask (class in luigi.contrib.lsf) LocalOpener (class in luigi.contrib.opener) LocalSGEJobTask (class in luigi.contrib.sge) LocalTarget (class in luigi) (class in luigi.local_target) location (luigi.contrib.bigquery.BQDataset attribute) lock_pid_dir (luigi.interface.core attribute) lock_size (luigi.interface.core attribute) log_level (luigi.interface.core attribute) logger (in module luigi.contrib.scalding) logging_conf_file (luigi.interface.core attribute) LSFJobTask (class in luigi.contrib.lsf) luigi (module) luigi.batch_notifier (module) luigi.cmdline (module) luigi.cmdline_parser (module) luigi.configuration (module) luigi.configuration.base_parser (module) luigi.configuration.cfg_parser (module) luigi.configuration.core (module) luigi.configuration.toml_parser (module) luigi.contrib (module) luigi.contrib.batch (module) luigi.contrib.beam_dataflow (module) luigi.contrib.bigquery (module) luigi.contrib.bigquery_avro (module) luigi.contrib.datadog_metric (module) luigi.contrib.dataproc (module) luigi.contrib.docker_runner (module) luigi.contrib.dropbox (module) luigi.contrib.ecs (module) luigi.contrib.esindex (module) luigi.contrib.external_daily_snapshot (module) luigi.contrib.external_program (module) luigi.contrib.ftp (module) luigi.contrib.gcp (module) luigi.contrib.gcs (module) luigi.contrib.hadoop (module) luigi.contrib.hadoop_jar (module) luigi.contrib.hdfs (module) luigi.contrib.hdfs.abstract_client (module) luigi.contrib.hdfs.clients (module)

luigi.contrib.hdfs.config (module) luigi.contrib.hdfs.error (module) luigi.contrib.hdfs.format (module) luigi.contrib.hdfs.hadoopcli_clients (module) luigi.contrib.hdfs.snakebite_client (module) luigi.contrib.hdfs.target (module) luigi.contrib.hdfs.webhdfs_client (module) luigi.contrib.hive (module) luigi.contrib.kubernetes (module) luigi.contrib.lsf (module) luigi.contrib.lsf_runner (module) luigi.contrib.mongodb (module) luigi.contrib.mrrunner (module) luigi.contrib.mssqldb (module) luigi.contrib.mysqldb (module) luigi.contrib.opener (module) luigi.contrib.pai (module) luigi.contrib.pig (module) luigi.contrib.postgres (module) luigi.contrib.presto (module) luigi.contrib.pyspark_runner (module) luigi.contrib.rdbms (module) luigi.contrib.redis_store (module) luigi.contrib.redshift (module) luigi.contrib.s3 (module) luigi.contrib.salesforce (module) luigi.contrib.scalding (module) luigi.contrib.sge (module) luigi.contrib.sge_runner (module) luigi.contrib.simulate (module) luigi.contrib.spark (module) luigi.contrib.sparkey (module) luigi.contrib.sqla (module) luigi.contrib.ssh (module) luigi.contrib.target (module) luigi.contrib.webhdfs (module) luigi.date_interval (module) luigi.db_task_history (module) luigi.event (module) luigi.execution_summary (module) luigi.format (module) luigi.freezing (module) luigi.interface (module) luigi.local_target (module) luigi.lock (module) luigi.metrics (module) luigi.mock (module) luigi.notifications (module) luigi.parameter (module) luigi.process (module) luigi.retcodes (module) luigi.rpc (module) luigi.scheduler (module) luigi.server (module) luigi.setup_logging (module) luigi.target (module) luigi.task (module) luigi.task_history (module) luigi.task_register (module) luigi.task_status (module) luigi.tools (module) luigi.tools.deps (module) luigi.tools.deps_tree (module) luigi.tools.luigi_grep (module) luigi.tools.range (module) luigi.util (module) luigi.worker (module) luigi_run() (in module luigi.cmdline) LuigiConfigParser (class in luigi.configuration) (class in luigi.configuration.cfg_parser) luigid() (in module luigi.cmdline) LuigiGrep (class in luigi.tools.luigi_grep) LuigiRunResult (class in luigi.execution_summary) LuigiStatusCode (class in luigi) (class in luigi.execution_summary) LuigiTomlParser (class in luigi.configuration) (class in luigi.configuration.toml_parser)

M

main() (in module luigi.contrib.lsf_runner) (in module luigi.contrib.mrrunner) (in module luigi.contrib.sge_runner) (in module luigi.tools.deps) (in module luigi.tools.deps_tree) (in module luigi.tools.luigi_grep) (luigi.contrib.hadoop_jar.HadoopJarJobTask method) (luigi.contrib.spark.PySparkTask method) main_class (luigi.contrib.dataproc.DataprocSparkTask attribute) make_dataset() (luigi.contrib.bigquery.BigQueryClient method) makedirs() (luigi.local_target.LocalTarget method) (luigi.LocalTarget method) map_column() (luigi.contrib.postgres.CopyToTable method) mapper() (luigi.contrib.hadoop.JobTask method) mapping (luigi.contrib.esindex.CopyToIndex attribute) mark_as_done() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) marker_doc_type (luigi.contrib.esindex.ElasticsearchTarget attribute) marker_index (luigi.contrib.esindex.ElasticsearchTarget attribute) marker_index_document_id() (luigi.contrib.esindex.ElasticsearchTarget method) marker_index_hist_size (luigi.contrib.esindex.CopyToIndex attribute) marker_key() (luigi.contrib.redis_store.RedisTarget method) marker_prefix (luigi.contrib.redis_store.RedisTarget attribute) marker_table (luigi.contrib.mssqldb.MSSqlTarget attribute) (luigi.contrib.mysqldb.MySqlTarget attribute) (luigi.contrib.postgres.PostgresTarget attribute) (luigi.contrib.redshift.RedshiftTarget attribute) (luigi.contrib.sqla.SQLAlchemyTarget attribute) master (luigi.contrib.spark.SparkSubmitTask attribute) master_disk_size (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) master_node_type (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) max_age (luigi.server.cors attribute) max_bad_records (luigi.contrib.bigquery.BigQueryLoadTask attribute) max_batch_size (luigi.Task attribute) (luigi.task.Task attribute) max_graph_nodes (luigi.scheduler.scheduler attribute) max_keep_alive_idle_duration (luigi.worker.worker attribute) max_num_workers (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) max_reschedules (luigi.worker.worker attribute) max_retrials (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask attribute) max_shown_tasks (luigi.scheduler.scheduler attribute) may_prune() (luigi.scheduler.SimpleTaskState method) memory_flag (luigi.contrib.lsf.LSFJobTask attribute) memoryMB (luigi.contrib.pai.TaskRole attribute) merge_batch_results() (luigi.contrib.salesforce.QuerySalesforce method) MetastoreClient (class in luigi.contrib.hive) method (luigi.notifications.email attribute) metric_namespace (luigi.contrib.datadog_metric.datadog attribute) metrics_collector (luigi.scheduler.scheduler attribute) MetricsCollector (class in luigi.metrics) MetricsCollectors (class in luigi.metrics) MetricsHandler (class in luigi.server) minFailedTaskCount (luigi.contrib.pai.TaskRole attribute) minSucceededTaskCount (luigi.contrib.pai.TaskRole attribute) minutes_back (luigi.tools.range.RangeByMinutesBase attribute) minutes_forward (luigi.tools.range.RangeByMinutesBase attribute) minutes_interval (luigi.tools.range.RangeByMinutesBase attribute) missing_data (luigi.retcodes.retcode attribute) missing_datetimes() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutes method) (luigi.tools.range.RangeDaily method) (luigi.tools.range.RangeHourly method) MISSING_EXT (luigi.execution_summary.LuigiStatusCode attribute) (luigi.LuigiStatusCode attribute) MissingParameterException MissingParentDirectory MixedUnicodeBytesFormat (class in luigi.format)

MixedUnicodeBytesWrapper (class in luigi.format) MixinBigQueryBulkComplete (class in luigi.contrib.bigquery) MixinBigqueryBulkComplete (in module luigi.contrib.bigquery) MixinNaiveBulkComplete (class in luigi.task) mkdir() (in module luigi.contrib.hdfs.clients) (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClientCdh3 method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.local_target.LocalFileSystem method) (luigi.mock.MockFileSystem method) (luigi.target.FileSystem method) MockFileSystem (class in luigi.mock) MockOpener (class in luigi.contrib.opener) MockTarget (class in luigi.mock) module (luigi.interface.core attribute) MongoCellTarget (class in luigi.contrib.mongodb) MongoCollectionTarget (class in luigi.contrib.mongodb) MongoCountTarget (class in luigi.contrib.mongodb) MongoRangeTarget (class in luigi.contrib.mongodb) MongoTarget (class in luigi.contrib.mongodb) Month (class in luigi.date_interval) MonthParameter (class in luigi) (class in luigi.parameter) months_back (luigi.tools.range.RangeMonthly attribute) months_forward (luigi.tools.range.RangeMonthly attribute) most_common() (in module luigi.tools.range) mount_tmp (luigi.contrib.docker_runner.DockerTask attribute) move() (luigi.contrib.dropbox.DropboxClient method) (luigi.LocalTarget method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.local_target.LocalFileSystem method) (luigi.local_target.LocalTarget method) (luigi.mock.MockFileSystem method) (luigi.mock.MockTarget method) (luigi.target.FileSystem method) move_dir() (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.LocalTarget method) (luigi.local_target.LocalTarget method) move_to_final_destination() (luigi.contrib.dropbox.AtomicWritableDropboxFile method) (luigi.contrib.ftp.AtomicFtpFile method) (luigi.contrib.gcs.AtomicGCSFile method) (luigi.contrib.s3.AtomicS3File method) (luigi.contrib.webhdfs.AtomicWebHdfsFile method) (luigi.local_target.atomic_file method) (luigi.target.AtomicLocalFile method) moving_start() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method) moving_stop() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method) mr_priority (luigi.contrib.hadoop.BaseHadoopJobTask attribute) MSSqlTarget (class in luigi.contrib.mssqldb) MultiReplacer (class in luigi.contrib.postgres) MySqlTarget (class in luigi.contrib.mysqldb)

N

n_cpu (luigi.contrib.sge.SGEJobTask attribute) n_cpu_flag (luigi.contrib.lsf.LSFJobTask attribute) n_pending_last_scheduled (luigi.worker.GetWorkResponse attribute) n_pending_tasks (luigi.worker.GetWorkResponse attribute) n_reduce_tasks (luigi.contrib.hadoop.JobTask attribute) (luigi.contrib.hive.HiveQueryTask attribute) n_unique_pending (luigi.worker.GetWorkResponse attribute) name (luigi.contrib.docker_runner.DockerTask attribute) (luigi.contrib.kubernetes.KubernetesJobTask attribute) (luigi.contrib.pai.PaiTask attribute) (luigi.contrib.pai.TaskRole attribute) (luigi.contrib.spark.PySparkTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) (luigi.db_task_history.TaskParameter attribute) (luigi.db_task_history.TaskRecord attribute) namenode_host (luigi.contrib.hdfs.config.hdfs attribute) namenode_port (luigi.contrib.hdfs.config.hdfs attribute) names (luigi.contrib.opener.LocalOpener attribute) (luigi.contrib.opener.MockOpener attribute) (luigi.contrib.opener.S3Opener attribute) namespace() (in module luigi) (in module luigi.task) network (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) network_mode (luigi.contrib.docker_runner.DockerTask attribute) NEWLINE_DELIMITED_JSON (luigi.contrib.bigquery.DestinationFormat attribute) (luigi.contrib.bigquery.SourceFormat attribute) NewlineFormat (class in luigi.format) NewlineWrapper (class in luigi.format) next() (luigi.date_interval.DateInterval method) next_in_enumeration() (luigi.DateParameter method) (luigi.IntParameter method) (luigi.MonthParameter method) (luigi.Parameter method) (luigi.YearParameter method) (luigi.parameter.DateParameter method) (luigi.parameter.IntParameter method) (luigi.parameter.MonthParameter method) (luigi.parameter.Parameter method) (luigi.parameter.YearParameter method) NO_DEFAULT (luigi.configuration.cfg_parser.LuigiConfigParser attribute) (luigi.configuration.LuigiConfigParser attribute) (luigi.configuration.LuigiTomlParser attribute) (luigi.configuration.toml_parser.LuigiTomlParser attribute)

no_install_shutdown_handler (luigi.worker.worker attribute) no_lock (luigi.interface.core attribute) no_tarball (luigi.contrib.sge.SGEJobTask attribute) no_tls (luigi.notifications.smtp attribute) no_unpicklable_properties() (luigi.Task method) (luigi.task.Task method) NoMetricsCollector (class in luigi.metrics) NONE (luigi.contrib.bigquery.Compression attribute) none (luigi.metrics.MetricsCollectors attribute) NoOpenerError NopFormat (class in luigi.format) NopHistory (class in luigi.task_history) normalize() (luigi.BoolParameter method) (luigi.ChoiceParameter method) (luigi.DateParameter method) (luigi.DictParameter method) (luigi.ListParameter method) (luigi.MonthParameter method) (luigi.Parameter method) (luigi.YearParameter method) (luigi.parameter.BoolParameter method) (luigi.parameter.ChoiceParameter method) (luigi.parameter.DateParameter method) (luigi.parameter.DictParameter method) (luigi.parameter.ListParameter method) (luigi.parameter.MonthParameter method) (luigi.parameter.Parameter method) (luigi.parameter.YearParameter method) NOT_RUN (luigi.execution_summary.LuigiStatusCode attribute) (luigi.LuigiStatusCode attribute) not_run (luigi.retcodes.retcode attribute) NotADirectory now (luigi.tools.range.RangeBase attribute) null_values (luigi.contrib.rdbms.CopyToTable attribute) num_executors (luigi.contrib.spark.SparkSubmitTask attribute) num_failures() (luigi.scheduler.Failures method) num_pending_tasks() (luigi.scheduler.SimpleTaskState method) num_workers (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) NumericalParameter (class in luigi) (class in luigi.parameter)

O

object_name (luigi.contrib.salesforce.QuerySalesforce attribute) of (luigi.tools.range.RangeBase attribute) of_cls (luigi.tools.range.RangeBase attribute) of_params (luigi.tools.range.RangeBase attribute) OKBLUE (luigi.tools.deps_tree.bcolors attribute) OKGREEN (luigi.tools.deps_tree.bcolors attribute) on_failure() (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.Task method) (luigi.task.Task method) on_success() (luigi.Task method) (luigi.task.Task method) on_successful_output_validation() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) on_successful_run() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) open() (luigi.contrib.dropbox.DropboxTarget method) (luigi.LocalTarget method) (luigi.contrib.ftp.RemoteTarget method) (luigi.contrib.gcs.GCSTarget method) (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.contrib.opener.OpenerRegistry method) (luigi.contrib.postgres.PostgresTarget method) (luigi.contrib.s3.S3Target method) (luigi.contrib.sqla.SQLAlchemyTarget method) (luigi.contrib.ssh.RemoteTarget method) (luigi.contrib.webhdfs.WebHdfsTarget method) (luigi.local_target.LocalTarget method) (luigi.mock.MockTarget method) (luigi.target.FileSystemTarget method) Opener (class in luigi.contrib.opener) OpenerError OpenerRegistry (class in luigi.contrib.opener) OpenPai (class in luigi.contrib.pai) OptionalParameter (class in luigi) (class in luigi.parameter) options() (luigi.server.RPCHandler method) OrderedSet (class in luigi.scheduler)

output (luigi.contrib.hdfs.format.CompatibleHdfsFormat attribute) (luigi.contrib.hdfs.format.PlainDirFormat attribute) (luigi.contrib.hdfs.format.PlainFormat attribute) (luigi.contrib.lsf.LSFJobTask attribute) (luigi.format.Bzip2Format attribute) (luigi.format.GzipFormat attribute) (luigi.format.MixedUnicodeBytesFormat attribute) (luigi.format.NewlineFormat attribute) (luigi.format.TextFormat attribute) output() (luigi.contrib.esindex.CopyToIndex method) (luigi.Task method) (luigi.contrib.hive.ExternalHiveTask method) (luigi.contrib.kubernetes.KubernetesJobTask method) (luigi.contrib.mysqldb.CopyToTable method) (luigi.contrib.pai.PaiTask method) (luigi.contrib.pig.PigJobTask method) (luigi.contrib.postgres.CopyToTable method) (luigi.contrib.postgres.PostgresQuery method) (luigi.contrib.presto.PrestoTask method) (luigi.contrib.rdbms.CopyToTable method) (luigi.contrib.rdbms.Query method) (luigi.contrib.redshift.KillOpenRedshiftSessions method) (luigi.contrib.redshift.RedshiftQuery method) (luigi.contrib.redshift.RedshiftUnloadTask method) (luigi.contrib.redshift.S3CopyToTable method) (luigi.contrib.s3.S3EmrTask method) (luigi.contrib.s3.S3FlagTask method) (luigi.contrib.s3.S3PathTask method) (luigi.contrib.sqla.CopyToTable method) (luigi.task.Task method) output_dir (luigi.contrib.pai.PaiTask attribute) outputDir (luigi.contrib.pai.PaiJob attribute) OutputPipeProcessWrapper (class in luigi.format) owner_email (luigi.Task attribute) (luigi.task.Task attribute)

P

package_binary (luigi.contrib.hadoop.BaseHadoopJobTask attribute) packages (luigi.contrib.spark.SparkSubmitTask attribute) pai_url (luigi.contrib.pai.OpenPai attribute) PaiJob (class in luigi.contrib.pai) PaiTask (class in luigi.contrib.pai) parallel_env (luigi.contrib.sge.SGEJobTask attribute) parallel_scheduling (luigi.interface.core attribute) parallel_scheduling_processes (luigi.interface.core attribute) param_args (luigi.Task attribute) (luigi.task.Task attribute) param_name (luigi.tools.range.RangeBase attribute) Parameter (class in luigi) (class in luigi.parameter) parameter_to_datetime() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method) ParameterException parameters (luigi.contrib.batch.BatchTask attribute) (luigi.db_task_history.TaskRecord attribute) (luigi.task_history.StoredTask attribute) parameters_to_datetime() (luigi.tools.range.RangeBase method) (luigi.tools.range.RangeByMinutesBase method) (luigi.tools.range.RangeDailyBase method) (luigi.tools.range.RangeHourlyBase method) (luigi.tools.range.RangeMonthly method) ParameterVisibility (class in luigi.parameter) parse() (luigi.BoolParameter method) (luigi.ChoiceParameter method) (luigi.DateIntervalParameter method) (luigi.DateMinuteParameter method) (luigi.DictParameter method) (luigi.EnumParameter method) (luigi.FloatParameter method) (luigi.IntParameter method) (luigi.ListParameter method) (luigi.NumericalParameter method) (luigi.OptionalParameter method) (luigi.Parameter method) (luigi.TaskParameter method) (luigi.TimeDeltaParameter method) (luigi.TupleParameter method) (luigi.date_interval.Custom class method) (luigi.date_interval.Date class method) (luigi.date_interval.DateInterval class method) (luigi.date_interval.Month class method) (luigi.date_interval.Week class method) (luigi.date_interval.Year class method) (luigi.parameter.BoolParameter method) (luigi.parameter.ChoiceParameter method) (luigi.parameter.DateIntervalParameter method) (luigi.parameter.DateMinuteParameter method) (luigi.parameter.DictParameter method) (luigi.parameter.EnumListParameter method) (luigi.parameter.EnumParameter method) (luigi.parameter.FloatParameter method) (luigi.parameter.IntParameter method) (luigi.parameter.ListParameter method) (luigi.parameter.NumericalParameter method) (luigi.parameter.OptionalParameter method) (luigi.parameter.Parameter method) (luigi.parameter.TaskParameter method) (luigi.parameter.TimeDeltaParameter method) (luigi.parameter.TupleParameter method) parse_results() (in module luigi.contrib.salesforce) parsing (luigi.BoolParameter attribute) (luigi.parameter.BoolParameter attribute) partition (luigi.contrib.hive.ExternalHiveTask attribute) (luigi.contrib.presto.PrestoTask attribute) partition_spec() (luigi.contrib.hive.HiveClient method) (luigi.contrib.hive.HiveCommandClient method) (luigi.contrib.hive.MetastoreClient method) (luigi.contrib.hive.WarehouseHiveClient method) password (luigi.contrib.pai.OpenPai attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.presto.presto attribute) (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.contrib.redshift.KillOpenRedshiftSessions attribute) (luigi.contrib.salesforce.salesforce attribute) (luigi.notifications.smtp attribute) path (luigi.contrib.hive.HivePartitionTarget attribute) (luigi.contrib.s3.S3EmrTask attribute) (luigi.contrib.s3.S3FlagTask attribute) (luigi.contrib.s3.S3PathTask attribute) pause() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) pause_enabled (luigi.scheduler.scheduler attribute) peek() (luigi.scheduler.OrderedSet method) percentage_progress (luigi.contrib.presto.PrestoClient attribute) pid (luigi.contrib.sqla.SQLAlchemyTarget.Connection attribute) PidLockAlreadyTakenExit pig_command_path() (luigi.contrib.pig.PigJobTask method) pig_env_vars() (luigi.contrib.pig.PigJobTask method) pig_home() (luigi.contrib.pig.PigJobTask method) pig_options() (luigi.contrib.pig.PigJobTask method) pig_parameters() (luigi.contrib.pig.PigJobTask method) pig_properties() (luigi.contrib.pig.PigJobTask method) pig_script_path() (luigi.contrib.pig.PigJobTask method) PigJobError PigJobTask (class in luigi.contrib.pig) PigRunContext (class in luigi.contrib.pig) ping() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) ping_interval (luigi.worker.worker attribute) PIPE (luigi.contrib.bigquery.FieldDelimiter attribute) pipe_reader() (luigi.contrib.hdfs.format.CompatibleHdfsFormat method) (luigi.contrib.hdfs.format.PlainDirFormat method) (luigi.contrib.hdfs.format.PlainFormat method) (luigi.format.Bzip2Format method) (luigi.format.ChainFormat method) (luigi.format.Format class method) (luigi.format.GzipFormat method) (luigi.format.NopFormat method) (luigi.format.WrappedFormat method)

pipe_writer() (luigi.contrib.hdfs.format.CompatibleHdfsFormat method) (luigi.contrib.hdfs.format.PlainDirFormat method) (luigi.contrib.hdfs.format.PlainFormat method) (luigi.format.Bzip2Format method) (luigi.format.ChainFormat method) (luigi.format.Format class method) (luigi.format.GzipFormat method) (luigi.format.NopFormat method) (luigi.format.WrappedFormat method) PlainDirFormat (class in luigi.contrib.hdfs.format) PlainFormat (class in luigi.contrib.hdfs.format) pod_creation_wait_interal (luigi.contrib.kubernetes.KubernetesJobTask attribute) poll_interval (luigi.contrib.kubernetes.KubernetesJobTask attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.presto.presto attribute) poll_time (luigi.contrib.batch.BatchTask attribute) (luigi.contrib.lsf.LSFJobTask attribute) (luigi.contrib.sge.SGEJobTask attribute) pool (luigi.contrib.hadoop.BaseHadoopJobTask attribute) (luigi.contrib.hadoop.hadoop attribute) pop() (luigi.scheduler.OrderedSet method) Popen() (luigi.contrib.ssh.RemoteContext method) Port (class in luigi.contrib.pai) port (luigi.contrib.esindex.CopyToIndex attribute) (luigi.contrib.hdfs.webhdfs_client.webhdfs attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.presto.presto attribute) (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.notifications.smtp attribute) portList (luigi.contrib.pai.TaskRole attribute) portNumber (luigi.contrib.pai.Port attribute) post() (luigi.server.RPCHandler method) post_copy() (luigi.contrib.rdbms.CopyToTable method) (luigi.contrib.redshift.S3CopyToTable method) post_copy_metacolums() (luigi.contrib.redshift.S3CopyToTable method) PostgresQuery (class in luigi.contrib.postgres) PostgresTarget (class in luigi.contrib.postgres) prefix (luigi.notifications.email attribute) prefix_search() (luigi.tools.luigi_grep.LuigiGrep method) prepare_outputs() (luigi.contrib.hive.HiveQueryRunner method) presto (class in luigi.contrib.presto) PrestoClient (class in luigi.contrib.presto) PrestoTarget (class in luigi.contrib.presto) PrestoTask (class in luigi.contrib.presto) pretty_id (luigi.scheduler.Task attribute) prev() (luigi.date_interval.DateInterval method) previous() (in module luigi.util) print_exception() (in module luigi.contrib.mrrunner) print_header (luigi.contrib.bigquery.BigQueryExtractTask attribute) print_pod_logs_on_exit (luigi.contrib.kubernetes.KubernetesJobTask attribute) print_tree() (in module luigi.tools.deps_tree) PrintHeader (class in luigi.contrib.bigquery) priority (luigi.Task attribute) (luigi.task.Task attribute) PRIVATE (luigi.parameter.ParameterVisibility attribute) PROCESS_FAILURE (luigi.Event attribute) (luigi.event.Event attribute) process_resources() (luigi.Task method) (luigi.task.Task method) PROCESSING_TIME (luigi.Event attribute) (luigi.event.Event attribute) program_args() (luigi.contrib.external_program.ExternalProgramTask method) (luigi.contrib.spark.SparkSubmitTask method) program_environment() (luigi.contrib.external_program.ExternalProgramTask method) (luigi.contrib.external_program.ExternalPythonProgramTask method) (luigi.contrib.spark.SparkSubmitTask method) PROGRESS (luigi.Event attribute) (luigi.event.Event attribute) project (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) project_id (luigi.contrib.bigquery.BQDataset attribute) prometheus (luigi.metrics.MetricsCollectors attribute) properties_file (luigi.contrib.spark.SparkSubmitTask attribute) protocol (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask attribute) prune() (luigi.contrib.redshift.S3CopyToTable method) (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) (luigi.scheduler.Worker method) prune_column (luigi.contrib.redshift.S3CopyToTable attribute) prune_date (luigi.contrib.redshift.S3CopyToTable attribute) prune_on_get_work (luigi.scheduler.scheduler attribute) prune_table (luigi.contrib.redshift.S3CopyToTable attribute) PUBLIC (luigi.parameter.ParameterVisibility attribute) purge_existing_index (luigi.contrib.esindex.CopyToIndex attribute) put() (luigi.contrib.ftp.RemoteFileSystem method) (luigi.contrib.ftp.RemoteTarget method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.contrib.ssh.RemoteTarget method) (luigi.worker.DequeQueue method) put_multipart() (luigi.contrib.s3.S3Client method) put_multiple() (luigi.contrib.gcs.GCSClient method) put_string() (luigi.contrib.gcs.GCSClient method) (luigi.contrib.s3.S3Client method) py_files (luigi.contrib.spark.SparkSubmitTask attribute) py_packages (luigi.contrib.spark.PySparkTask attribute) pyspark_driver_python (luigi.contrib.spark.SparkSubmitTask attribute) pyspark_python (luigi.contrib.spark.SparkSubmitTask attribute) PySparkRunner (class in luigi.contrib.pyspark_runner) PySparkSessionRunner (class in luigi.contrib.pyspark_runner) PySparkTask (class in luigi.contrib.spark)

Q

queries (luigi.contrib.redshift.S3CopyToTable attribute) Query (class in luigi.contrib.rdbms) query (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.rdbms.Query attribute) query() (luigi.contrib.hive.HiveQueryTask method) (luigi.contrib.salesforce.SalesforceAPI method)

query_all() (luigi.contrib.salesforce.SalesforceAPI method) query_mode (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) query_more() (luigi.contrib.salesforce.SalesforceAPI method) QueryMode (class in luigi.contrib.bigquery) QuerySalesforce (class in luigi.contrib.salesforce) queue (luigi.contrib.spark.SparkSubmitTask attribute) queue_flag (luigi.contrib.lsf.LSFJobTask attribute)

R

raise_in_complete (luigi.notifications.TestNotificationsTask attribute) raise_on_error (luigi.contrib.esindex.CopyToIndex attribute) raises (luigi.rpc.URLLibFetcher attribute) RangeBase (class in luigi.tools.range) RangeByMinutes (class in luigi.tools.range) RangeByMinutesBase (class in luigi.tools.range) RangeDaily (class in luigi.tools.range) RangeDailyBase (class in luigi.tools.range) RangeEvent (class in luigi.tools.range) RangeHourly (class in luigi.tools.range) RangeHourlyBase (class in luigi.tools.range) RangeMonthly (class in luigi.tools.range) re_enable() (luigi.scheduler.SimpleTaskState method) re_enable_task() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) read() (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) (luigi.contrib.dropbox.ReadableDropboxFile method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.mongodb.MongoCellTarget method) (luigi.contrib.mongodb.MongoCollectionTarget method) (luigi.contrib.mongodb.MongoCountTarget method) (luigi.contrib.mongodb.MongoRangeTarget method) (luigi.contrib.s3.ReadableS3File method) (luigi.contrib.webhdfs.ReadableWebHdfsFile method) (luigi.format.NewlineWrapper method) readable() (luigi.contrib.dropbox.ReadableDropboxFile method) (luigi.contrib.s3.ReadableS3File method) (luigi.format.InputPipeProcessWrapper method) (luigi.format.OutputPipeProcessWrapper method) ReadableDropboxFile (class in luigi.contrib.dropbox) ReadableS3File (class in luigi.contrib.s3) ReadableWebHdfsFile (class in luigi.contrib.webhdfs) reader() (luigi.contrib.hadoop.JobTask method) readlines() (luigi.contrib.webhdfs.ReadableWebHdfsFile method) receiver (luigi.notifications.email attribute) RecentRunHandler (class in luigi.server) record_task_history (luigi.scheduler.scheduler attribute) recursive_listdir_cmd (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient attribute) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClientApache1 attribute) recursively_freeze() (in module luigi.freezing) RedisTarget (class in luigi.contrib.redis_store) RedshiftManifestTask (class in luigi.contrib.redshift) RedshiftQuery (class in luigi.contrib.redshift) RedshiftTarget (class in luigi.contrib.redshift) RedshiftUnloadTask (class in luigi.contrib.redshift) reducer (luigi.contrib.hadoop.JobTask attribute) reducers_max (luigi.contrib.hive.HiveQueryTask attribute) reflect (luigi.contrib.sqla.CopyToTable attribute) region (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) Register (class in luigi.task_register) register_job_definition() (luigi.contrib.batch.BatchClient method) reload() (luigi.configuration.base_parser.BaseParser class method) (luigi.configuration.LuigiConfigParser class method) (luigi.configuration.cfg_parser.LuigiConfigParser class method) relpath() (luigi.contrib.scalding.ScaldingJobTask method) RemoteCalledProcessError RemoteContext (class in luigi.contrib.ssh) RemoteFileSystem (class in luigi.contrib.ftp) (class in luigi.contrib.ssh) RemoteScheduler (class in luigi) (class in luigi.rpc) RemoteTarget (class in luigi.contrib.ftp) (class in luigi.contrib.ssh) remove() (in module luigi.contrib.hdfs.clients) (luigi.LocalTarget method) (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.ftp.RemoteFileSystem method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClientCdh3 method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.local_target.LocalFileSystem method) (luigi.local_target.LocalTarget method) (luigi.mock.MockFileSystem method) (luigi.target.FileSystem method) (luigi.target.FileSystemTarget method) remove_delay (luigi.scheduler.scheduler attribute) rename() (in module luigi.contrib.hdfs.clients) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.mock.MockTarget method) (luigi.target.FileSystem method) rename_dont_move() (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.local_target.LocalFileSystem method) (luigi.target.FileSystem method) requests_kwargs (luigi.contrib.presto.PrestoTask attribute) requests_session (luigi.contrib.presto.PrestoTask attribute) RequestsFetcher (class in luigi.rpc) requires (class in luigi.util) requires() (luigi.contrib.scalding.ScaldingJobTask method) (luigi.Task method) (luigi.task.Task method) (luigi.tools.range.RangeBase method)

requires_hadoop() (luigi.contrib.hadoop.BaseHadoopJobTask method) requires_local() (luigi.contrib.hadoop.BaseHadoopJobTask method) resource_flag (luigi.contrib.lsf.LSFJobTask attribute) resource_list() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) resources (luigi.Task attribute) (luigi.task.Task attribute) resources() (luigi.scheduler.Scheduler method) respond() (luigi.worker.SchedulerMessage method) restful() (luigi.contrib.salesforce.SalesforceAPI method) retcode (class in luigi.retcodes) retry_count (luigi.contrib.pai.PaiTask attribute) (luigi.Task attribute) (luigi.scheduler.RetryPolicy attribute) (luigi.scheduler.scheduler attribute) (luigi.task.Task attribute) retry_delay (luigi.scheduler.scheduler attribute) retry_external_tasks (luigi.worker.worker attribute) retryCount (luigi.contrib.pai.PaiJob attribute) RetryPolicy (class in luigi.scheduler) reverse (luigi.tools.range.RangeBase attribute) RootPathHandler (class in luigi.server) rows() (luigi.contrib.mysqldb.CopyToTable method) (luigi.contrib.postgres.CopyToTable method) (luigi.contrib.sqla.CopyToTable method) rpc_message_callback() (in module luigi.worker) rpc_method() (in module luigi.scheduler) RPCError, [1] RPCHandler (class in luigi.server) run (luigi.ExternalTask attribute) (luigi.task.ExternalTask attribute) run() (in module luigi) (in module luigi.interface) (in module luigi.server) (luigi.Task method) (luigi.contrib.batch.BatchTask method) (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) (luigi.contrib.bigquery.BigQueryCreateViewTask method) (luigi.contrib.bigquery.BigQueryExtractTask method) (luigi.contrib.bigquery.BigQueryLoadTask method) (luigi.contrib.bigquery.BigQueryRunQueryTask method) (luigi.contrib.bigquery_avro.BigQueryLoadAvro method) (luigi.contrib.dataproc.CreateDataprocClusterTask method) (luigi.contrib.dataproc.DataprocPysparkTask method) (luigi.contrib.dataproc.DataprocSparkTask method) (luigi.contrib.dataproc.DeleteDataprocClusterTask method) (luigi.contrib.docker_runner.DockerTask method) (luigi.contrib.ecs.ECSTask method) (luigi.contrib.esindex.CopyToIndex method) (luigi.contrib.external_program.ExternalProgramTask method) (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.contrib.kubernetes.KubernetesJobTask method) (luigi.contrib.lsf.LSFJobTask method) (luigi.contrib.lsf.LocalLSFJobTask method) (luigi.contrib.mrrunner.Runner method) (luigi.contrib.mysqldb.CopyToTable method) (luigi.contrib.pai.PaiTask method) (luigi.contrib.pig.PigJobTask method) (luigi.contrib.postgres.CopyToTable method) (luigi.contrib.postgres.PostgresQuery method) (luigi.contrib.presto.PrestoTask method) (luigi.contrib.pyspark_runner.AbstractPySparkRunner method) (luigi.contrib.rdbms.Query method) (luigi.contrib.redshift.KillOpenRedshiftSessions method) (luigi.contrib.redshift.RedshiftManifestTask method) (luigi.contrib.redshift.RedshiftUnloadTask method) (luigi.contrib.redshift.S3CopyToTable method) (luigi.contrib.salesforce.QuerySalesforce method) (luigi.contrib.sge.LocalSGEJobTask method) (luigi.contrib.sge.SGEJobTask method) (luigi.contrib.spark.PySparkTask method) (luigi.contrib.sparkey.SparkeyExportTask method) (luigi.contrib.sqla.CopyToTable method) (luigi.notifications.TestNotificationsTask method) (luigi.task.Task method) (luigi.worker.ContextManagedTaskProcess method) (luigi.worker.KeepAliveThread method) (luigi.worker.TaskProcess method) (luigi.worker.Worker method) run_and_track_hadoop_job() (in module luigi.contrib.hadoop) run_combiner() (luigi.contrib.hadoop.JobTask method) run_hive() (in module luigi.contrib.hive) run_hive_cmd() (in module luigi.contrib.hive) run_hive_script() (in module luigi.contrib.hive) run_job (luigi.contrib.hadoop.JobRunner attribute) run_job() (luigi.contrib.bigquery.BigQueryClient method) (luigi.contrib.hadoop.HadoopJobRunner method) (luigi.contrib.hadoop.LocalJobRunner method) (luigi.contrib.hadoop_jar.HadoopJarJobRunner method) (luigi.contrib.hive.HiveQueryRunner method) (luigi.contrib.scalding.ScaldingJobRunner method) run_locally (luigi.contrib.sge.SGEJobTask attribute) run_mapper() (luigi.contrib.hadoop.JobTask method) run_reducer() (luigi.contrib.hadoop.JobTask method) run_with_retcodes() (in module luigi.retcodes) RunAnywayTarget (class in luigi.contrib.simulate) Runner (class in luigi.contrib.mrrunner) runner (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) running_tasks (luigi.worker.GetWorkResponse attribute) runtime_flag (luigi.contrib.lsf.LSFJobTask attribute)

S

s3 (luigi.contrib.s3.S3Client attribute) s3_load_path() (luigi.contrib.redshift.S3CopyToTable method) s3_unload_path (luigi.contrib.redshift.RedshiftUnloadTask attribute) S3Client (class in luigi.contrib.s3) S3CopyJSONToTable (class in luigi.contrib.redshift) S3CopyToTable (class in luigi.contrib.redshift) S3EmrTarget (class in luigi.contrib.s3) S3EmrTask (class in luigi.contrib.s3) S3FlagTarget (class in luigi.contrib.s3) S3FlagTask (class in luigi.contrib.s3) S3Opener (class in luigi.contrib.opener) S3PathTask (class in luigi.contrib.s3) S3Target (class in luigi.contrib.s3) salesforce (class in luigi.contrib.salesforce) SalesforceAPI (class in luigi.contrib.salesforce) sample() (luigi.contrib.hadoop.LocalJobRunner method) sandbox_name (luigi.contrib.salesforce.QuerySalesforce attribute) save_job_info (luigi.contrib.lsf.LSFJobTask attribute) sb_security_token (luigi.contrib.salesforce.salesforce attribute) sc (luigi.contrib.pyspark_runner.SparkContextEntryPoint attribute) ScaldingJobRunner (class in luigi.contrib.scalding) ScaldingJobTask (class in luigi.contrib.scalding) Scheduler (class in luigi.scheduler) scheduler (class in luigi.scheduler) scheduler_host (luigi.interface.core attribute) scheduler_port (luigi.interface.core attribute) scheduler_url (luigi.interface.core attribute) SchedulerMessage (class in luigi.worker) scheduling_error (luigi.retcodes.retcode attribute) SCHEDULING_FAILED (luigi.execution_summary.LuigiStatusCode attribute) (luigi.LuigiStatusCode attribute) schema (luigi.contrib.bigquery.BigQueryLoadTask attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.sqla.CopyToTable attribute) security_token (luigi.contrib.salesforce.salesforce attribute) seekable() (luigi.contrib.dropbox.ReadableDropboxFile method) (luigi.contrib.s3.ReadableS3File method) (luigi.format.InputPipeProcessWrapper method) (luigi.format.OutputPipeProcessWrapper method) SelectedRunHandler (class in luigi.server) send_email() (in module luigi.notifications) (luigi.batch_notifier.BatchNotifier method) send_email_sendgrid() (in module luigi.notifications) send_email_ses() (in module luigi.notifications) send_email_smtp() (in module luigi.notifications) send_email_sns() (in module luigi.notifications) send_error_email() (in module luigi.notifications) send_failure_email (luigi.worker.worker attribute) send_messages (luigi.scheduler.scheduler attribute) send_scheduler_message() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) sender (luigi.notifications.email attribute) sendgrid (class in luigi.notifications) separator (luigi.contrib.sparkey.SparkeyExportTask attribute) serialize() (luigi.DictParameter method) (luigi.EnumParameter method) (luigi.ListParameter method) (luigi.OptionalParameter method) (luigi.Parameter method) (luigi.TaskParameter method) (luigi.TimeDeltaParameter method) (luigi.parameter.DictParameter method) (luigi.parameter.EnumListParameter method) (luigi.parameter.EnumParameter method) (luigi.parameter.ListParameter method) (luigi.parameter.OptionalParameter method) (luigi.parameter.Parameter method) (luigi.parameter.ParameterVisibility method) (luigi.parameter.TaskParameter method) (luigi.parameter.TimeDeltaParameter method) service_account (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) session_props (luigi.contrib.presto.PrestoTask attribute) set() (luigi.configuration.cfg_parser.LuigiConfigParser method) (luigi.configuration.LuigiConfigParser method) (luigi.configuration.LuigiTomlParser method) (luigi.configuration.toml_parser.LuigiTomlParser method) set_batch_running() (luigi.scheduler.SimpleTaskState method) set_batcher() (luigi.scheduler.SimpleTaskState method) set_dataproc_client() (in module luigi.contrib.dataproc) set_params() (luigi.scheduler.Task method) set_state() (luigi.scheduler.SimpleTaskState method) set_status() (luigi.scheduler.SimpleTaskState method) set_task_progress_percentage() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method)

set_task_status_message() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) set_worker_processes() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) (luigi.worker.Worker method) settings (luigi.contrib.esindex.CopyToIndex attribute) setup() (luigi.contrib.spark.PySparkTask method) (luigi.setup_logging.BaseLogging class method) setup_remote() (luigi.contrib.spark.PySparkTask method) SGEJobTask (class in luigi.contrib.sge) shared_tmp_dir (luigi.contrib.lsf.LSFJobTask attribute) (luigi.contrib.sge.SGEJobTask attribute) shmMB (luigi.contrib.pai.TaskRole attribute) signal_complete() (luigi.contrib.kubernetes.KubernetesJobTask method) SimpleTaskState (class in luigi.scheduler) SingleProcessPool (class in luigi.worker) skip_leading_rows (luigi.contrib.bigquery.BigQueryLoadTask attribute) slot_to_dict() (in module luigi.contrib.pai) smtp (class in luigi.notifications) snakebite_autoconfig (luigi.contrib.hdfs.config.hdfs attribute) SnakebiteHdfsClient (class in luigi.contrib.hdfs.snakebite_client) SOAP_NS (luigi.contrib.salesforce.SalesforceAPI attribute) soql (luigi.contrib.salesforce.QuerySalesforce attribute) source (luigi.contrib.presto.PrestoTask attribute) source() (luigi.contrib.scalding.ScaldingJobTask method) source_format (luigi.contrib.bigquery.BigQueryLoadTask attribute) (luigi.contrib.bigquery_avro.BigQueryLoadAvro attribute) source_uris() (luigi.contrib.bigquery.BigQueryLoadTask method) (luigi.contrib.bigquery_avro.BigQueryLoadAvro method) SourceFormat (class in luigi.contrib.bigquery) spark (luigi.contrib.pyspark_runner.SparkSessionEntryPoint attribute) spark_command() (luigi.contrib.spark.SparkSubmitTask method) spark_submit (luigi.contrib.spark.SparkSubmitTask attribute) spark_version (luigi.contrib.spark.SparkSubmitTask attribute) SparkContextEntryPoint (class in luigi.contrib.pyspark_runner) SparkeyExportTask (class in luigi.contrib.sparkey) SparkSessionEntryPoint (class in luigi.contrib.pyspark_runner) SparkSubmitTask (class in luigi.contrib.spark) spec_schema (luigi.contrib.kubernetes.KubernetesJobTask attribute) SQLAlchemyTarget (class in luigi.contrib.sqla) SQLAlchemyTarget.Connection (class in luigi.contrib.sqla) ssh() (luigi.contrib.hadoop_jar.HadoopJarJobTask method) ssl (luigi.notifications.smtp attribute) stable_done_cooldown_secs (luigi.scheduler.scheduler attribute) staging_location (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) START (luigi.Event attribute) (luigi.event.Event attribute) start (luigi.tools.range.RangeBase attribute) (luigi.tools.range.RangeByMinutesBase attribute) (luigi.tools.range.RangeDailyBase attribute) (luigi.tools.range.RangeHourlyBase attribute) (luigi.tools.range.RangeMonthly attribute) start_session() (luigi.contrib.salesforce.SalesforceAPI method) state (luigi.scheduler.Worker attribute) state_path (luigi.scheduler.scheduler attribute) statsd_host (luigi.contrib.datadog_metric.datadog attribute) statsd_port (luigi.contrib.datadog_metric.datadog attribute) status_search() (luigi.tools.luigi_grep.LuigiGrep method) stop (luigi.tools.range.RangeBase attribute) (luigi.tools.range.RangeByMinutesBase attribute) (luigi.tools.range.RangeDailyBase attribute) (luigi.tools.range.RangeHourlyBase attribute) (luigi.tools.range.RangeMonthly attribute) stop() (in module luigi.server) (luigi.worker.KeepAliveThread method) StoredTask (class in luigi.task_history) stream_for_searching_tracking_url (luigi.contrib.external_program.ExternalProgramTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) submit_job() (luigi.contrib.batch.BatchClient method) (luigi.contrib.dataproc.DataprocBaseTask method) submit_pyspark_job() (luigi.contrib.dataproc.DataprocBaseTask method) submit_spark_job() (luigi.contrib.dataproc.DataprocBaseTask method) subnetwork (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) SUCCESS (luigi.Event attribute) (luigi.LuigiStatusCode attribute) (luigi.event.Event attribute) (luigi.execution_summary.LuigiStatusCode attribute) SUCCESS_WITH_RETRY (luigi.execution_summary.LuigiStatusCode attribute) (luigi.LuigiStatusCode attribute) summary() (in module luigi.execution_summary) summary_length (luigi.execution_summary.execution_summary attribute) supervise (luigi.contrib.spark.SparkSubmitTask attribute)

T

TAB (luigi.contrib.bigquery.FieldDelimiter attribute) table (luigi.contrib.hive.ExternalHiveTask attribute) (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.contrib.sqla.CopyToTable attribute) table_attributes (luigi.contrib.redshift.S3CopyToTable attribute) table_constraints (luigi.contrib.redshift.S3CopyToTable attribute) table_exists() (luigi.contrib.bigquery.BigQueryClient method) (luigi.contrib.hive.HiveClient method) (luigi.contrib.hive.HiveCommandClient method) (luigi.contrib.hive.MetastoreClient method) (luigi.contrib.hive.WarehouseHiveClient method) table_location() (luigi.contrib.hive.HiveClient method) (luigi.contrib.hive.HiveCommandClient method) (luigi.contrib.hive.MetastoreClient method) (luigi.contrib.hive.WarehouseHiveClient method) table_schema() (luigi.contrib.hive.ApacheHiveCommandClient method) (luigi.contrib.hive.HiveClient method) (luigi.contrib.hive.HiveCommandClient method) (luigi.contrib.hive.MetastoreClient method) (luigi.contrib.hive.WarehouseHiveClient method) table_type (luigi.contrib.redshift.S3CopyToTable attribute) take_lock (luigi.interface.core attribute) Target (class in luigi) (class in luigi.target) Task (class in luigi) (class in luigi.scheduler) (class in luigi.task) task_def (luigi.contrib.ecs.ECSTask attribute) task_def_arn (luigi.contrib.ecs.ECSTask attribute) task_failed (luigi.retcodes.retcode attribute) task_family (luigi.Task attribute) (luigi.task.Task attribute) (luigi.task_history.StoredTask attribute) (luigi.task_register.Register attribute) task_finished() (luigi.db_task_history.DbTaskHistory method) (luigi.task_history.NopHistory method) (luigi.task_history.TaskHistory method) task_history (luigi.scheduler.Scheduler attribute) task_id (luigi.contrib.hadoop.BaseHadoopJobTask attribute) (luigi.db_task_history.TaskEvent attribute) (luigi.db_task_history.TaskParameter attribute) (luigi.db_task_history.TaskRecord attribute) (luigi.worker.GetWorkResponse attribute) task_id_str() (in module luigi.task) task_limit (luigi.tools.range.RangeBase attribute) (luigi.worker.worker attribute) task_list() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) task_module (luigi.Task attribute) (luigi.task.Task attribute) task_names() (luigi.task_register.Register class method) task_namespace (luigi.Task attribute) (luigi.task.Task attribute) task_process_context (luigi.worker.worker attribute) task_scheduled() (luigi.db_task_history.DbTaskHistory method) (luigi.task_history.NopHistory method) (luigi.task_history.TaskHistory method) task_search() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) task_started() (luigi.db_task_history.DbTaskHistory method) (luigi.task_history.NopHistory method) (luigi.task_history.TaskHistory method) task_value() (luigi.Parameter method) (luigi.parameter.Parameter method) TaskClassAmbigiousException TaskClassException

TaskClassNotFoundException TaskEvent (class in luigi.db_task_history) TaskException TaskHistory (class in luigi.task_history) taskNumber (luigi.contrib.pai.TaskRole attribute) TaskParameter (class in luigi) (class in luigi.db_task_history) (class in luigi.parameter) TaskProcess (class in luigi.worker) TaskRecord (class in luigi.db_task_history) TaskRole (class in luigi.contrib.pai) taskRoles (luigi.contrib.pai.PaiJob attribute) tasks (luigi.contrib.pai.PaiTask attribute) tasks_str() (luigi.task_register.Register class method) TaskStatusReporter (class in luigi.worker) temp_dir (luigi.contrib.simulate.RunAnywayTarget attribute) temp_location (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) temp_time (luigi.contrib.simulate.RunAnywayTarget attribute) temporary_path() (luigi.contrib.dropbox.DropboxTarget method) (luigi.target.FileSystemTarget method) terminate() (luigi.worker.TaskProcess method) TestNotificationsTask (class in luigi.notifications) text_target (luigi.contrib.redshift.RedshiftManifestTask attribute) TextFormat (class in luigi.format) TextWrapper (class in luigi.format) TimeDeltaParameter (class in luigi) (class in luigi.parameter) timeout (luigi.contrib.esindex.CopyToIndex attribute) TIMEOUT (luigi.Event attribute) (luigi.event.Event attribute) timeout (luigi.notifications.smtp attribute) (luigi.worker.worker attribute) tmp_dir (luigi.contrib.hdfs.config.hdfs attribute) tmp_path (luigi.contrib.ssh.AtomicRemoteFileWriter attribute) (luigi.target.AtomicLocalFile attribute) tmppath() (in module luigi.contrib.hdfs.config) to_str_params() (luigi.Task method) (luigi.task.Task method) to_string() (luigi.date_interval.Custom method) (luigi.date_interval.Date method) (luigi.date_interval.DateInterval method) (luigi.date_interval.Month method) (luigi.date_interval.Week method) (luigi.date_interval.Year method) total_executor_cores (luigi.contrib.spark.SparkSubmitTask attribute) touch() (luigi.contrib.esindex.ElasticsearchTarget method) (luigi.contrib.mssqldb.MSSqlTarget method) (luigi.contrib.mysqldb.MySqlTarget method) (luigi.contrib.postgres.PostgresTarget method) (luigi.contrib.redis_store.RedisTarget method) (luigi.contrib.sqla.SQLAlchemyTarget method) touchz() (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.snakebite_client.SnakebiteHdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) TracebackWrapper (class in luigi.worker) track_and_progress() (luigi.contrib.pig.PigJobTask method) track_job() (in module luigi.contrib.lsf) tracking_url_pattern (luigi.contrib.external_program.ExternalProgramTask attribute) (luigi.contrib.spark.SparkSubmitTask attribute) trigger_event() (luigi.Task method) (luigi.task.Task method) TRUE (luigi.contrib.bigquery.PrintHeader attribute) truncate_table() (luigi.contrib.redshift.S3CopyToTable method) ts (luigi.db_task_history.TaskEvent attribute) tunnel() (luigi.contrib.ssh.RemoteContext method) TupleParameter (class in luigi) (class in luigi.parameter)

U

udf_resource_uris (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) unhandled_exception (luigi.retcodes.retcode attribute) unique (luigi.contrib.simulate.RunAnywayTarget attribute) UnknownParameterException unload_options (luigi.contrib.redshift.RedshiftUnloadTask attribute) unload_query (luigi.contrib.redshift.RedshiftUnloadTask attribute) unpause() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update() (luigi.batch_notifier.BatchNotifier method) (luigi.scheduler.Worker method) update_id (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.contrib.redshift.KillOpenRedshiftSessions attribute) update_id() (luigi.contrib.esindex.CopyToIndex method) (luigi.contrib.sqla.CopyToTable method) update_metrics() (luigi.scheduler.SimpleTaskState method) update_metrics_task_started() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update_progress_percentage() (luigi.worker.TaskStatusReporter method) update_resource() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update_resources() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update_status() (luigi.scheduler.SimpleTaskState method)

update_status_message() (luigi.worker.TaskStatusReporter method) update_tracking_url() (luigi.worker.TaskStatusReporter method) update_view() (luigi.contrib.bigquery.BigQueryClient method) upload() (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) upstream (class in luigi.tools.deps) UPSTREAM_SEVERITY_KEY() (in module luigi.scheduler) uri (luigi.contrib.bigquery.BQTable attribute) url (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient attribute) URLLibFetcher (class in luigi.rpc) use_cmdline_section (luigi.interface.core attribute) (luigi.Task attribute) (luigi.task.Task attribute) use_db_timestamps (luigi.contrib.postgres.PostgresTarget attribute) (luigi.contrib.redshift.RedshiftTarget attribute) use_legacy_sql (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) use_sandbox (luigi.contrib.salesforce.QuerySalesforce attribute) user (luigi.contrib.hdfs.webhdfs_client.webhdfs attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.presto.presto attribute) (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.rdbms.Query attribute) (luigi.contrib.redshift.KillOpenRedshiftSessions attribute) username (luigi.contrib.pai.OpenPai attribute) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.salesforce.salesforce attribute) (luigi.notifications.smtp attribute) UTF_8 (luigi.contrib.bigquery.Encoding attribute)

V

validate_output() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) value (luigi.db_task_history.TaskParameter attribute) version (luigi.contrib.hdfs.config.hadoopcli attribute)

view (luigi.contrib.bigquery.BigQueryCreateViewTask attribute) virtual_cluster (luigi.contrib.pai.PaiTask attribute) virtualCluster (luigi.contrib.pai.PaiJob attribute) virtualenv (luigi.contrib.external_program.ExternalPythonProgramTask attribute)

W

wait_for_job() (luigi.contrib.dataproc.DataprocBaseTask method) wait_interval (luigi.worker.worker attribute) wait_jitter (luigi.worker.worker attribute) wait_on_job() (luigi.contrib.batch.BatchClient method) walk() (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) WarehouseHiveClient (class in luigi.contrib.hive) webhdfs (class in luigi.contrib.hdfs.webhdfs_client) WebHdfsClient (class in luigi.contrib.hdfs.webhdfs_client) WebHdfsTarget (class in luigi.contrib.webhdfs) Week (class in luigi.date_interval) WithPrestoClient (class in luigi.contrib.presto) work() (luigi.contrib.lsf.LSFJobTask method) (luigi.contrib.sge.SGEJobTask method) Worker (class in luigi.scheduler) (class in luigi.worker) worker (class in luigi.worker) worker_disconnect_delay (luigi.scheduler.scheduler attribute) worker_disk_size (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) worker_disk_type (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) worker_list() (luigi.RemoteScheduler method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) worker_machine_type (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute) worker_node_type (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) worker_normal_count (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) worker_preemptible_count (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) worker_state (luigi.worker.GetWorkResponse attribute) worker_timeout (luigi.Task attribute) (luigi.task.Task attribute)

workers (luigi.interface.core attribute) wrap_traceback() (in module luigi.notifications) WrappedFormat (class in luigi.format) wrapper_cls (luigi.format.MixedUnicodeBytesFormat attribute) (luigi.format.NewlineFormat attribute) (luigi.format.TextFormat attribute) WrapperTask (class in luigi) (class in luigi.task) writable() (luigi.contrib.dropbox.ReadableDropboxFile method) (luigi.contrib.s3.ReadableS3File method) (luigi.format.InputPipeProcessWrapper method) (luigi.format.OutputPipeProcessWrapper method) write() (luigi.contrib.mongodb.MongoCellTarget method) (luigi.contrib.mongodb.MongoRangeTarget method) (luigi.format.MixedUnicodeBytesWrapper method) (luigi.format.NewlineWrapper method) (luigi.format.OutputPipeProcessWrapper method) WRITE_APPEND (luigi.contrib.bigquery.WriteDisposition attribute) write_disposition (luigi.contrib.bigquery.BigQueryLoadTask attribute) (luigi.contrib.bigquery.BigQueryRunQueryTask attribute) WRITE_EMPTY (luigi.contrib.bigquery.WriteDisposition attribute) write_pid() (in module luigi.process) WRITE_TRUNCATE (luigi.contrib.bigquery.WriteDisposition attribute) WriteDisposition (class in luigi.contrib.bigquery) writeLine() (luigi.format.OutputPipeProcessWrapper method) writelines() (luigi.format.MixedUnicodeBytesWrapper method) (luigi.format.NewlineWrapper method) writer() (luigi.contrib.hadoop.JobTask method) WRITES_BEFORE_FLUSH (luigi.format.OutputPipeProcessWrapper attribute)

Y

Year (class in luigi.date_interval)

YearParameter (class in luigi) (class in luigi.parameter)

Z

zone (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys attribute)