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.Task property) acquire_for() (in module luigi.lock) active_deadline_seconds (luigi.contrib.kubernetes.KubernetesJobTask property) 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.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.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) add_scheduling_fail() (luigi.batch_notifier.BatchNotifier method) add_task() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) add_task_batcher() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) add_worker() (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 property) allow_null_origin (luigi.server.cors attribute) allow_quoted_new_lines (luigi.contrib.bigquery.BigQueryLoadTask property) 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 property) (luigi.contrib.spark.SparkSubmitTask attribute) AMBIGUOUS_CLASS (luigi.task_register.Register attribute) announce_scheduling_failure() (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 property) 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 property) AsyncCompletionException 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 property) auth_method (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask property) authFile (luigi.contrib.pai.PaiJob attribute) auto_namespace() (in module luigi.task) auto_remove (luigi.contrib.docker_runner.DockerTask property) autocommit (luigi.contrib.rdbms.Query property) autoscaling_algorithm (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) AVRO (luigi.contrib.bigquery.DestinationFormat attribute) (luigi.contrib.bigquery.SourceFormat attribute)

B

backoff_limit (luigi.contrib.kubernetes.KubernetesJobTask property) 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.Task class method) batchable (luigi.task.Task property) 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) BigQueryExecutionError 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 property) block_on_batch() (luigi.contrib.salesforce.SalesforceAPI method) BoolParameter (class in luigi.parameter) BQDataset (class in luigi.contrib.bigquery) BQTable (class in luigi.contrib.bigquery) BROKEN_TASK (luigi.event.Event attribute) build() (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.MixinNaiveBulkComplete class method) (luigi.task.Task class method) bulk_size (luigi.contrib.mysqldb.CopyToTable property) BulkCompleteNotImplementedError ByIdHandler (class in luigi.server) ByNameHandler (class in luigi.server) ByParamsHandler (class in luigi.server) ByTaskIdHandler (class in luigi.server) bytes_per_reducer (luigi.contrib.hive.HiveQueryTask attribute) Bzip2Format (class in luigi.format)

C

cache_task_completion (luigi.worker.worker attribute) 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 property) ChainFormat (class in luigi.format) check_complete() (in module luigi.worker) check_complete_cached() (in module luigi.worker) check_complete_on_run (luigi.worker.worker attribute) check_output() (luigi.contrib.ssh.RemoteContext method) check_parameter() (luigi.mypy.TaskPlugin 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.webhdfs_client.WebHdfsClient method) ChoiceListParameter (class in luigi.parameter) ChoiceParameter (class in luigi.parameter) chown() (luigi.contrib.hdfs.abstract_client.HdfsFileSystem method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) chunk_size (luigi.contrib.esindex.CopyToIndex property) (luigi.contrib.sqla.CopyToTable attribute) cleanup_on_error() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) clear() (luigi.mock.MockFileSystem method) clear_failures() (luigi.scheduler.Task method) clear_instance_cache() (luigi.task_register.Register class method) client (luigi.contrib.hdfs.config.hdfs attribute) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient property) client_type (luigi.contrib.hdfs.webhdfs_client.webhdfs attribute) client_version (luigi.contrib.hdfs.config.hdfs attribute) clone() (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.rpc.RemoteScheduler method) (luigi.rpc.RequestsFetcher method) (luigi.rpc.URLLibFetcher 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 property) codeDir (luigi.contrib.pai.PaiJob attribute) collect_attributes() (luigi.mypy.TaskTransformer method) column_separator (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.sqla.CopyToTable attribute) columns (luigi.contrib.rdbms.CopyToTable attribute) (luigi.contrib.sqla.CopyToTable attribute) combined_overrides (luigi.contrib.ecs.ECSTask property) 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 property) (luigi.contrib.ecs.ECSTask property) (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.contrib.dataproc.CreateDataprocClusterTask method) (luigi.contrib.dataproc.DeleteDataprocClusterTask method) (luigi.contrib.pai.PaiTask method) (luigi.notifications.TestNotificationsTask method) (luigi.task.DynamicRequirements 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 property) conf (luigi.contrib.spark.SparkSubmitTask property) Config (class in luigi.task) config (luigi.setup_logging.BaseLogging attribute) configure_http_handler() (luigi.metrics.MetricsCollector method) configure_job() (luigi.contrib.bigquery.BigQueryExtractTask method) (luigi.contrib.bigquery.BigQueryLoadTask method) (luigi.contrib.bigquery.BigQueryRunQueryTask 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 property) container_options (luigi.contrib.docker_runner.DockerTask property) container_tmp_dir (luigi.contrib.docker_runner.DockerTask property) content_type (luigi.contrib.salesforce.QuerySalesforce property) ContextManagedTaskProcess (class in luigi.worker) copies (class in luigi.util) copy() (luigi.contrib.bigquery.BigQueryClient 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.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.mock.MockFileSystem method) (luigi.target.FileSystem method) copy_json_options (luigi.contrib.redshift.S3CopyJSONToTable property) copy_options (luigi.contrib.redshift.S3CopyToTable property) 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.webhdfs_client.WebHdfsClient method) (luigi.contrib.presto.PrestoTarget method) count_last_scheduled (luigi.worker.worker attribute) count_pending() (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 property) 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) custom (luigi.metrics.MetricsCollectors attribute) custom_complete (luigi.task.DynamicRequirements attribute)

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 property) data_interchange_format (luigi.contrib.hadoop.BaseHadoopJobTask attribute) database (luigi.contrib.hive.ExternalHiveTask attribute) (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (luigi.contrib.redshift.KillOpenRedshiftSessions property) 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 property) 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.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.parameter) DateInterval (class in luigi.date_interval) DateIntervalParameter (class in luigi.parameter) DateMinuteParameter (class in luigi.parameter) DateParameter (class in luigi.parameter) dates() (luigi.date_interval.DateInterval method) DateSecondParameter (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) db_error_code() (in module luigi.contrib.postgres) DbTaskHistory (class in luigi.db_task_history) decrease_running_resources() (luigi.worker.TaskStatusReporter method) decrease_running_task_resources() (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 property) 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 property) delete_table() (luigi.contrib.bigquery.BigQueryClient method) DeleteDataprocClusterTask (class in luigi.contrib.dataproc) dep_graph() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) DEPENDENCY_DISCOVERED (luigi.event.Event attribute) DEPENDENCY_MISSING (luigi.event.Event attribute) DEPENDENCY_PRESENT (luigi.event.Event attribute) deploy_mode (luigi.contrib.spark.SparkSubmitTask property) deprecated_date_format (luigi.parameter.DateMinuteParameter attribute) DeprecatedBotoClientException deps() (luigi.contrib.hadoop.BaseHadoopJobTask method) (luigi.task.Task method) DequeQueue (class in luigi.worker) dereference() (in module luigi.contrib.hadoop) deserialize() (luigi.mypy.TaskAttribute class method) destination_format (luigi.contrib.bigquery.BigQueryExtractTask property) destination_uris (luigi.contrib.bigquery.BigQueryExtractTask property) DestinationFormat (class in luigi.contrib.bigquery) dfs_paths() (in module luigi.tools.deps) DictParameter (class in luigi.parameter) disable_hard_timeout (luigi.scheduler.RetryPolicy attribute) (luigi.scheduler.scheduler attribute) (luigi.task.Task property) 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) (luigi.task.Task property) disable_window_seconds (luigi.task.Task property) disable_worker() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) disable_workers() (luigi.scheduler.SimpleTaskState method) disabled (luigi.task.Task attribute) discard() (luigi.scheduler.OrderedSet method) disk_size_gb (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) dispatch_scheduler_message() (luigi.worker.Worker method) do_prune() (luigi.contrib.redshift.S3CopyToTable method) do_truncate_table (luigi.contrib.redshift.S3CopyToTable property) do_work_on_compute_node() (in module luigi.contrib.lsf_runner) doc_type (luigi.contrib.esindex.CopyToIndex property) docker_url (luigi.contrib.docker_runner.DockerTask property) 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 property) driver_cores (luigi.contrib.spark.SparkSubmitTask property) driver_java_options (luigi.contrib.spark.SparkSubmitTask property) driver_library_path (luigi.contrib.spark.SparkSubmitTask property) driver_memory (luigi.contrib.spark.SparkSubmitTask property) 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 DynamicRequirements (class in luigi.task)

E

echo (luigi.contrib.sqla.CopyToTable attribute) ecs_task_ids (luigi.contrib.ecs.ECSTask property) ECSTask (class in luigi.contrib.ecs) 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 property) (luigi.server.cors attribute) Encoding (class in luigi.contrib.bigquery) encoding (luigi.contrib.bigquery.BigQueryLoadTask property) ENDC (luigi.tools.deps_tree.bcolors attribute) engine (luigi.contrib.sqla.SQLAlchemyTarget property) (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.parameter) environment (luigi.contrib.datadog_metric.datadog attribute) (luigi.contrib.docker_runner.DockerTask property) 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.event) event_handler() (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 property) executor_memory (luigi.contrib.spark.SparkSubmitTask property) exists() (in module luigi.contrib.hdfs.clients) (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.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.mock.MockFileSystem method) (luigi.mock.MockTarget method) (luigi.target.FileSystem method) (luigi.target.FileSystemTarget method) (luigi.target.Target method)

expand_type() (luigi.mypy.TaskAttribute method) expand_typevar_from_subtype() (luigi.mypy.TaskAttribute method) expected_type (luigi.parameter.OptionalBoolParameter attribute) (luigi.parameter.OptionalDictParameter attribute) (luigi.parameter.OptionalFloatParameter attribute) (luigi.parameter.OptionalIntParameter attribute) (luigi.parameter.OptionalListParameter attribute) (luigi.parameter.OptionalParameter attribute) (luigi.parameter.OptionalParameterMixin attribute) (luigi.parameter.OptionalPathParameter attribute) (luigi.parameter.OptionalStrParameter attribute) (luigi.parameter.OptionalTupleParameter attribute) expiration (luigi.contrib.pai.OpenPai attribute) EXPLICIT_PARSING (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.task) extra_archives() (luigi.contrib.hadoop.JobTask method) extra_bsub_args (luigi.contrib.lsf.LSFJobTask attribute) extra_elasticsearch_args (luigi.contrib.esindex.CopyToIndex property) 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) FAILED_AND_SCHEDULING_FAILED (luigi.execution_summary.LuigiStatusCode attribute) FAILURE (luigi.event.Event attribute) FALSE (luigi.contrib.bigquery.PrintHeader attribute) family (luigi.tools.deps.upstream attribute) fetch() (luigi.rpc.RequestsFetcher method) (luigi.rpc.URLLibFetcher method) fetch_error() (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 property) (luigi.contrib.bigquery.BigQueryLoadTask property) FieldDelimiter (class in luigi.contrib.bigquery) file_pattern() (luigi.contrib.beam_dataflow.BeamDataflowJobTask method) FileAlreadyExists FileNotFoundException files (luigi.contrib.spark.PySparkTask property) (luigi.contrib.spark.SparkSubmitTask property) 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) find_task_by_task_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) flat_requirements (luigi.task.DynamicRequirements attribute) (luigi.task.DynamicRequirements property) flatten() (in module luigi.contrib.hadoop) (in module luigi.task) flatten_output() (in module luigi.task) flatten_results (luigi.contrib.bigquery.BigQueryRunQueryTask property) FloatParameter (class in luigi.parameter) folder_paths (luigi.contrib.redshift.RedshiftManifestTask attribute) force_multiprocessing (luigi.worker.worker attribute) force_pull (luigi.contrib.docker_runner.DockerTask property) force_send (luigi.notifications.email attribute) forgive_failures() (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.Task class method) from_utc() (in module luigi.server) FrozenOrderedDict (class in luigi.freezing) fs (luigi.contrib.dropbox.DropboxTarget property) (luigi.contrib.ftp.AtomicFtpFile property) (luigi.contrib.ftp.RemoteTarget property) (luigi.contrib.gcs.GCSFlagTarget attribute) (luigi.contrib.gcs.GCSTarget attribute) (luigi.contrib.hdfs.target.HdfsTarget property) (luigi.contrib.s3.S3FlagTarget attribute) (luigi.contrib.s3.S3Target attribute) (luigi.contrib.ssh.AtomicRemoteFileWriter property) (luigi.contrib.ssh.RemoteTarget property) (luigi.contrib.webhdfs.WebHdfsTarget attribute) (luigi.mock.MockTarget attribute) (luigi.target.FileSystemTarget property)

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 property) 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.target.AtomicLocalFile method) 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.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.contrib.ssh.RemoteTarget method) (luigi.metrics.MetricsCollectors class method) (luigi.server.AllRunHandler method) (luigi.server.ByIdHandler method) (luigi.server.ByNameHandler method) (luigi.server.ByParamsHandler method) (luigi.server.ByTaskIdHandler method) (luigi.server.MetricsHandler method) (luigi.server.RecentRunHandler method) (luigi.server.RootPathHandler method) (luigi.server.RPCHandler 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_base_class_hook() (luigi.mypy.TaskPlugin method) 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_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_function_hook() (luigi.mypy.TaskPlugin method) 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_opener() (luigi.contrib.opener.OpenerRegistry method) get_param_names() (luigi.task.Task class method) get_param_values() (luigi.task.Task class method) get_params() (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.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.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.Task class method) get_task_namespace() (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.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) get_task_requires() (in module luigi.tools.deps) get_task_status_message() (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.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 property) gpuNumber (luigi.contrib.pai.TaskRole attribute) gpuType (luigi.contrib.pai.PaiJob attribute) graph() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) graph_url (luigi.tools.luigi_grep.LuigiGrep property) 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 property) hadoop_user_name (luigi.contrib.spark.SparkSubmitTask property) 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.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) has_task_value() (luigi.parameter.Parameter method) has_value() (luigi.parameter.ParameterVisibility class method) 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 property) (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask property) (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (luigi.contrib.redshift.KillOpenRedshiftSessions property) (luigi.db_task_history.TaskRecord attribute) (luigi.notifications.smtp attribute) host_config_options (luigi.contrib.docker_runner.DockerTask property) 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 property)

I

id (luigi.db_task_history.TaskEvent attribute) (luigi.db_task_history.TaskRecord attribute) (luigi.worker.worker attribute) ignore_unconsumed (luigi.interface.core attribute) ignore_unknown_values (luigi.contrib.bigquery.BigQueryLoadTask property) image (luigi.contrib.docker_runner.DockerTask property) (luigi.contrib.pai.PaiJob attribute) (luigi.contrib.pai.PaiTask property) image_version (luigi.contrib.dataproc.CreateDataprocClusterTask attribute) IMPLICIT_PARSING (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 property) infer_bulk_complete_from_fs() (in module luigi.tools.range) info_uri (luigi.contrib.presto.PrestoClient property) 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.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.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.parameter) InvalidDeleteException, [1] InvalidQuery inverse_dep_graph() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) is_batchable() (luigi.scheduler.Task method) is_dir() (luigi.contrib.s3.S3Client method) is_error_5xx() (in module luigi.contrib.bigquery) (in module luigi.contrib.gcs) is_parameter_call() (luigi.mypy.TaskTransformer method) is_pause_enabled() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) is_paused() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) is_soql_file (luigi.contrib.salesforce.QuerySalesforce property) 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.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 property) 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 property) (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 property)

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 property) kubernetes (class in luigi.contrib.kubernetes) kubernetes_config (luigi.contrib.kubernetes.KubernetesJobTask property) kubernetes_namespace (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask property) 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 property) (luigi.contrib.kubernetes.KubernetesJobTask property) latest() (luigi.contrib.external_daily_snapshot.ExternalDailySnapshot class method) list() (luigi.contrib.s3.S3Client method) list_datasets() (luigi.contrib.bigquery.BigQueryClient 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.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem method) (luigi.mock.MockFileSystem method) (luigi.target.FileSystem method) ListParameter (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) LocalJobRunner (class in luigi.contrib.hadoop) LocalLSFJobTask (class in luigi.contrib.lsf) LocalOpener (class in luigi.contrib.opener) LocalSGEJobTask (class in luigi.contrib.sge) 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.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.mypy module luigi.notifications module luigi.parameter module luigi.process module luigi.retcodes module luigi.rpc module luigi.safe_extractor 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.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) map_column() (luigi.contrib.postgres.CopyToTable method) mapper() (luigi.contrib.hadoop.JobTask method) mapping (luigi.contrib.esindex.CopyToIndex property) mark_as_done() (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 property) 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 property) 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 property) max_batch_size (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 property) max_reschedules (luigi.worker.worker attribute) max_retrials (luigi.contrib.kubernetes.kubernetes attribute) (luigi.contrib.kubernetes.KubernetesJobTask property) 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) metrics_custom_import (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) 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.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.contrib.ssh.RemoteFileSystem 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 luigi.batch_notifier luigi.cmdline luigi.cmdline_parser luigi.configuration luigi.configuration.base_parser luigi.configuration.cfg_parser luigi.configuration.core luigi.configuration.toml_parser luigi.contrib luigi.contrib.batch luigi.contrib.beam_dataflow luigi.contrib.bigquery luigi.contrib.bigquery_avro luigi.contrib.datadog_metric luigi.contrib.dataproc luigi.contrib.docker_runner luigi.contrib.dropbox luigi.contrib.ecs luigi.contrib.esindex luigi.contrib.external_daily_snapshot luigi.contrib.external_program luigi.contrib.ftp luigi.contrib.gcp luigi.contrib.gcs luigi.contrib.hadoop luigi.contrib.hadoop_jar luigi.contrib.hdfs luigi.contrib.hdfs.abstract_client luigi.contrib.hdfs.clients luigi.contrib.hdfs.config luigi.contrib.hdfs.error luigi.contrib.hdfs.format luigi.contrib.hdfs.hadoopcli_clients luigi.contrib.hdfs.target luigi.contrib.hdfs.webhdfs_client luigi.contrib.hive luigi.contrib.kubernetes luigi.contrib.lsf luigi.contrib.lsf_runner luigi.contrib.mongodb luigi.contrib.mrrunner luigi.contrib.mssqldb luigi.contrib.mysqldb luigi.contrib.opener luigi.contrib.pai luigi.contrib.pig luigi.contrib.postgres luigi.contrib.presto luigi.contrib.pyspark_runner luigi.contrib.rdbms luigi.contrib.redis_store luigi.contrib.redshift luigi.contrib.s3 luigi.contrib.salesforce luigi.contrib.scalding luigi.contrib.sge luigi.contrib.sge_runner luigi.contrib.simulate luigi.contrib.spark luigi.contrib.sparkey luigi.contrib.sqla luigi.contrib.ssh luigi.contrib.target luigi.contrib.webhdfs luigi.date_interval luigi.db_task_history luigi.event luigi.execution_summary luigi.format luigi.freezing luigi.interface luigi.local_target luigi.lock luigi.metrics luigi.mock luigi.mypy luigi.notifications luigi.parameter luigi.process luigi.retcodes luigi.rpc luigi.safe_extractor luigi.scheduler luigi.server luigi.setup_logging luigi.target luigi.task luigi.task_history luigi.task_register luigi.task_status luigi.tools luigi.tools.deps luigi.tools.deps_tree luigi.tools.luigi_grep luigi.tools.range luigi.util luigi.worker

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.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 property) move() (luigi.contrib.dropbox.DropboxClient method) (luigi.contrib.gcs.GCSClient method) (luigi.contrib.hdfs.hadoopcli_clients.HdfsClient method) (luigi.contrib.hdfs.target.HdfsTarget method) (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient method) (luigi.contrib.s3.S3Client method) (luigi.mock.MockFileSystem method) (luigi.mock.MockTarget method) (luigi.target.FileSystem method) move_dir() (luigi.contrib.hdfs.target.HdfsTarget 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.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 property) (luigi.contrib.kubernetes.KubernetesJobTask property) (luigi.contrib.pai.PaiTask property) (luigi.contrib.pai.TaskRole attribute) (luigi.contrib.spark.PySparkTask property) (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.task) network (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) network_mode (luigi.contrib.docker_runner.DockerTask property) 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.parameter.DateParameter method) (luigi.parameter.IntParameter method) (luigi.parameter.MonthParameter method) (luigi.parameter.OptionalParameterMixin 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.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.parameter.BoolParameter method) (luigi.parameter.ChoiceListParameter method) (luigi.parameter.ChoiceParameter method) (luigi.parameter.DateParameter method) (luigi.parameter.DictParameter method) (luigi.parameter.ListParameter method) (luigi.parameter.MonthParameter method) (luigi.parameter.OptionalParameterMixin method) (luigi.parameter.Parameter method) (luigi.parameter.PathParameter method) (luigi.parameter.YearParameter method) NOT_RUN (luigi.execution_summary.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 property) num_failures() (luigi.scheduler.Task method) num_pending_tasks() (luigi.scheduler.SimpleTaskState method) num_workers (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) NumericalParameter (class in luigi.parameter)

O

object_name (luigi.contrib.salesforce.QuerySalesforce property) of (luigi.tools.range.RangeBase attribute) of_cls (luigi.tools.range.RangeBase property) 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.Task method) on_success() (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.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.mock.MockTarget method) (luigi.target.FileSystemTarget method) Opener (class in luigi.contrib.opener) OpenerError OpenerRegistry (class in luigi.contrib.opener) OpenerTarget() (in module luigi.contrib.opener) OpenPai (class in luigi.contrib.pai) OptionalBoolParameter (class in luigi.parameter) OptionalChoiceParameter (class in luigi.parameter) OptionalDictParameter (class in luigi.parameter) OptionalFloatParameter (class in luigi.parameter) OptionalIntParameter (class in luigi.parameter) OptionalListParameter (class in luigi.parameter) OptionalNumericalParameter (class in luigi.parameter) OptionalParameter (class in luigi.parameter) OptionalParameterMixin (class in luigi.parameter) OptionalParameterTypeWarning OptionalPathParameter (class in luigi.parameter)

OptionalStrParameter (class in luigi.parameter) OptionalTupleParameter (class in luigi.parameter) options() (luigi.server.RPCHandler method) optionxform (luigi.configuration.cfg_parser.LuigiConfigParser attribute) (luigi.configuration.LuigiConfigParser attribute) 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.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 property) outputDir (luigi.contrib.pai.PaiJob attribute) OutputPipeProcessWrapper (class in luigi.format) owner_email (luigi.task.Task property)

P

package_binary (luigi.contrib.hadoop.BaseHadoopJobTask attribute) packages (luigi.contrib.spark.SparkSubmitTask property) 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.Task property) param_name (luigi.tools.range.RangeBase attribute) Parameter (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 property) (luigi.db_task_history.TaskRecord attribute) (luigi.task_history.StoredTask property) 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) PARQUET (luigi.contrib.bigquery.SourceFormat attribute) parse() (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.ChoiceListParameter 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.OptionalParameterMixin 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.parameter.BoolParameter attribute) partition (luigi.contrib.hive.ExternalHiveTask attribute) (luigi.contrib.presto.PrestoTask property) 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.presto attribute) (luigi.contrib.presto.PrestoTask property) (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (luigi.contrib.redshift.KillOpenRedshiftSessions property) (luigi.contrib.salesforce.salesforce attribute) (luigi.notifications.smtp attribute) path (luigi.contrib.hive.HivePartitionTarget property) (luigi.contrib.s3.S3EmrTask attribute) (luigi.contrib.s3.S3FlagTask attribute) (luigi.contrib.s3.S3PathTask attribute) PathParameter (class in luigi.parameter) paths (luigi.task.DynamicRequirements attribute) (luigi.task.DynamicRequirements property) pause() (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 property) pickle_protocol (luigi.contrib.spark.PySparkTask property) 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.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) plugin() (in module luigi.mypy) pod_creation_wait_interal (luigi.contrib.kubernetes.KubernetesJobTask property) poll_interval (luigi.contrib.kubernetes.KubernetesJobTask property) (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask property) 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 property) (luigi.contrib.hdfs.webhdfs_client.webhdfs attribute) (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask property) (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (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 property) prev() (luigi.date_interval.DateInterval method) previous() (in module luigi.util) print_exception() (in module luigi.contrib.mrrunner) print_header (luigi.contrib.bigquery.BigQueryExtractTask property) print_pod_logs_on_exit (luigi.contrib.kubernetes.KubernetesJobTask property) print_tree() (in module luigi.tools.deps_tree) PrintHeader (class in luigi.contrib.bigquery) priority (luigi.task.Task attribute) PRIVATE (luigi.parameter.ParameterVisibility attribute) PROCESS_FAILURE (luigi.event.Event attribute) process_resources() (luigi.task.Task method) PROCESSING_TIME (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.Event attribute) project (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) project_id (luigi.contrib.bigquery.BQDataset attribute) prometheus (luigi.metrics.MetricsCollectors attribute) properties_file (luigi.contrib.spark.SparkSubmitTask property) protocol (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask property) prune() (luigi.contrib.redshift.S3CopyToTable method) (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) (luigi.scheduler.Worker method) prune_column (luigi.contrib.redshift.S3CopyToTable property) prune_date (luigi.contrib.redshift.S3CopyToTable property) prune_on_get_work (luigi.scheduler.scheduler attribute) prune_table (luigi.contrib.redshift.S3CopyToTable property) PUBLIC (luigi.parameter.ParameterVisibility attribute) purge_existing_index (luigi.contrib.esindex.CopyToIndex property) 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.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 property) py_packages (luigi.contrib.spark.PySparkTask property) pyspark_driver_python (luigi.contrib.spark.SparkSubmitTask property) pyspark_python (luigi.contrib.spark.SparkSubmitTask property) 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 property) Query (class in luigi.contrib.rdbms) query (luigi.contrib.bigquery.BigQueryRunQueryTask property) (luigi.contrib.presto.PrestoTask attribute) (luigi.contrib.rdbms.Query property) query() (luigi.contrib.hive.HiveQueryTask method) (luigi.contrib.salesforce.SalesforceAPI method)

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

R

raise_in_complete (luigi.notifications.TestNotificationsTask attribute) raise_on_error (luigi.contrib.esindex.CopyToIndex property) 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.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) recursively_unfreeze() (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 property) Register (class in luigi.task_register) register_job_definition() (luigi.contrib.batch.BatchClient method) reload() (luigi.configuration.base_parser.BaseParser class method) (luigi.configuration.cfg_parser.LuigiConfigParser class method) (luigi.configuration.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.rpc) RemoteTarget (class in luigi.contrib.ftp) (class in luigi.contrib.ssh) remove() (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.hadoopcli_clients.HdfsClientCdh3 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.mock.MockFileSystem method) (luigi.target.FileSystem method) (luigi.target.FileSystemTarget method) remove_delay (luigi.scheduler.scheduler attribute) remove_event_handler() (luigi.task.Task class method) 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.target.FileSystem method) requests_kwargs (luigi.contrib.presto.PrestoTask property) requests_session (luigi.contrib.presto.PrestoTask property) RequestsFetcher (class in luigi.rpc) requirements (luigi.task.DynamicRequirements attribute) requires (class in luigi.util) requires() (luigi.contrib.scalding.ScaldingJobTask 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.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) resources (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 property) (luigi.scheduler.RetryPolicy attribute) (luigi.scheduler.scheduler attribute) (luigi.task.Task property) 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 RPCHandler (class in luigi.server) run (luigi.task.ExternalTask attribute) run() (in module luigi.interface) (in module luigi.server) (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.LocalLSFJobTask method) (luigi.contrib.lsf.LSFJobTask 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_task_kwargs (luigi.contrib.ecs.ECSTask property) 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 property) running_tasks (luigi.worker.GetWorkResponse attribute) runtime_flag (luigi.contrib.lsf.LSFJobTask attribute)

S

s3 (luigi.contrib.s3.S3Client property) s3_load_path() (luigi.contrib.redshift.S3CopyToTable method) s3_unload_path (luigi.contrib.redshift.RedshiftUnloadTask property) 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) safe_extract() (luigi.safe_extractor.SafeExtractor method) SafeExtractor (class in luigi.safe_extractor) salesforce (class in luigi.contrib.salesforce) SalesforceAPI (class in luigi.contrib.salesforce) sample() (luigi.contrib.hadoop.LocalJobRunner method) sandbox_name (luigi.contrib.salesforce.QuerySalesforce property) 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) schema (luigi.contrib.bigquery.BigQueryLoadTask property) (luigi.contrib.presto.PrestoTask property) (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.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.mypy.TaskAttribute method) (luigi.parameter.ChoiceListParameter method) (luigi.parameter.DictParameter method) (luigi.parameter.EnumListParameter method) (luigi.parameter.EnumParameter method) (luigi.parameter.ListParameter method) (luigi.parameter.OptionalParameterMixin 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 property) session_props (luigi.contrib.presto.PrestoTask property) 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.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) set_task_status_message() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) set_worker_processes() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) (luigi.worker.Worker method) settings (luigi.contrib.esindex.CopyToIndex property) 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 property) slot_to_dict() (in module luigi.contrib.pai) smtp (class in luigi.notifications) SOAP_NS (luigi.contrib.salesforce.SalesforceAPI attribute) soql (luigi.contrib.salesforce.QuerySalesforce property) source (luigi.contrib.presto.PrestoTask property) source() (luigi.contrib.scalding.ScaldingJobTask method) source_format (luigi.contrib.bigquery.BigQueryLoadTask property) (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 property) spark_version (luigi.contrib.spark.SparkSubmitTask property) 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 property) 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 property) START (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 property) 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 property) SUCCESS (luigi.event.Event attribute) (luigi.execution_summary.LuigiStatusCode attribute) SUCCESS_WITH_RETRY (luigi.execution_summary.LuigiStatusCode attribute) summary() (in module luigi.execution_summary) summary_length (luigi.execution_summary.execution_summary attribute) supervise (luigi.contrib.spark.SparkSubmitTask property)

T

TAB (luigi.contrib.bigquery.FieldDelimiter attribute) table (luigi.contrib.hive.ExternalHiveTask attribute) (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (luigi.contrib.sqla.CopyToTable property) table_attributes (luigi.contrib.redshift.S3CopyToTable property) table_constraints (luigi.contrib.redshift.S3CopyToTable property) 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 property) take_lock (luigi.interface.core attribute) Target (class in luigi.target) Task (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.Task attribute) (luigi.task_history.StoredTask property) (luigi.task_register.Register property) task_finished() (luigi.db_task_history.DbTaskHistory method) (luigi.task_history.NopHistory method) (luigi.task_history.TaskHistory method) task_history (luigi.scheduler.Scheduler property) 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.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) task_module (luigi.task.Task property) task_names() (luigi.task_register.Register class method) task_namespace (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.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.Parameter method) TaskAttribute (class in luigi.mypy) 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.db_task_history) (class in luigi.parameter) TaskPlugin (class in luigi.mypy) 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 property) tasks_str() (luigi.task_register.Register class method) TaskStatusReporter (class in luigi.worker) TaskTransformer (class in luigi.mypy) temp_dir (luigi.contrib.simulate.RunAnywayTarget attribute) temp_location (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) 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.parameter) timeout (luigi.contrib.esindex.CopyToIndex property) TIMEOUT (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 property) (luigi.target.AtomicLocalFile property) tmppath() (in module luigi.contrib.hdfs.config) to_argument() (luigi.mypy.TaskAttribute method) to_str_params() (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) to_var() (luigi.mypy.TaskAttribute method) total_executor_cores (luigi.contrib.spark.SparkSubmitTask property) 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.webhdfs_client.WebHdfsClient method) traceback_max_length (luigi.notifications.email attribute) 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 property) transform() (luigi.mypy.TaskTransformer method) trigger_event() (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.parameter)

U

udf_resource_uris (luigi.contrib.bigquery.BigQueryRunQueryTask property) UnconsumedParameterWarning unhandled_exception (luigi.retcodes.retcode attribute) unique (luigi.contrib.simulate.RunAnywayTarget attribute) UnknownParameterException unload_options (luigi.contrib.redshift.RedshiftUnloadTask property) unload_query (luigi.contrib.redshift.RedshiftUnloadTask property) unpause() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update() (luigi.batch_notifier.BatchNotifier method) (luigi.scheduler.Worker method) update_container_overrides_command() (luigi.contrib.ecs.ECSTask static method) update_id (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (luigi.contrib.redshift.KillOpenRedshiftSessions property) update_id() (luigi.contrib.esindex.CopyToIndex method) (luigi.contrib.sqla.CopyToTable method) update_metrics() (luigi.scheduler.SimpleTaskState method) update_metrics_task_started() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update_progress_percentage() (luigi.worker.TaskStatusReporter method) update_resource() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) update_resources() (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 property) url (luigi.contrib.hdfs.webhdfs_client.WebHdfsClient property) URLLibFetcher (class in luigi.rpc) use_cmdline_section (luigi.interface.core attribute) (luigi.task.Task property) use_db_timestamps (luigi.contrib.postgres.PostgresTarget attribute) (luigi.contrib.redshift.RedshiftTarget attribute) use_legacy_sql (luigi.contrib.bigquery.BigQueryRunQueryTask property) use_sandbox (luigi.contrib.salesforce.QuerySalesforce property) user (luigi.contrib.hdfs.webhdfs_client.webhdfs attribute) (luigi.contrib.presto.presto attribute) (luigi.contrib.presto.PrestoTask property) (luigi.contrib.rdbms.CopyToTable property) (luigi.contrib.rdbms.Query property) (luigi.contrib.redshift.KillOpenRedshiftSessions property) username (luigi.contrib.pai.OpenPai attribute) (luigi.contrib.presto.PrestoTask property) (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 property) virtual_cluster (luigi.contrib.pai.PaiTask property) 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 property) worker_list() (luigi.rpc.RemoteScheduler method) (luigi.scheduler.Scheduler method) worker_machine_type (luigi.contrib.beam_dataflow.BeamDataflowJobTask attribute) (luigi.contrib.beam_dataflow.DataflowParamKeys property) 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.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.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 property) (luigi.contrib.bigquery.BigQueryRunQueryTask property) 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.parameter)

Z

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