Celery.Task.Definition (celery v0.1.0)

Copy Markdown View Source

Metadata and binding specification for a registered Celery task.

Summary

Types

param_spec()

@type param_spec() :: %{
  name: String.t(),
  raw_name: String.t(),
  has_default: boolean(),
  default: term()
}

t()

@type t() :: %Celery.Task.Definition{
  ack_on_failure_or_timeout: boolean() | nil,
  acks_late: boolean() | nil,
  arg_names: [atom()],
  arity: non_neg_integer(),
  autoretry_for: [module()],
  bind: boolean(),
  compression: String.t() | nil,
  default_retry_delay: number(),
  defaults: map(),
  exchange: String.t() | nil,
  fun: function() | nil,
  function: atom() | nil,
  ignore_result: boolean() | nil,
  max_retries: non_neg_integer() | :infinity | nil,
  metadata: term(),
  module: module() | nil,
  name: String.t(),
  options: keyword(),
  param_specs: [param_spec()],
  queue: String.t() | nil,
  rate_limit: String.t() | nil,
  reject_on_worker_lost: boolean() | nil,
  retry_backoff: boolean() | number(),
  retry_backoff_max: number(),
  retry_jitter: boolean(),
  routing_key: String.t() | nil,
  serializer: String.t() | nil,
  soft_time_limit: number() | nil,
  store_errors_even_if_ignored: boolean() | nil,
  time_limit: number() | nil,
  track_started: boolean() | nil,
  typing: boolean()
}