class Task

Overview

Background task.

By default, background tasks are processed sequentially.

Included Modules

Extended Modules

Direct Known Subclasses

Defined in:

models/task.cr
models/task/backup.cr
models/task/deliver.cr
models/task/fetch/hashtag.cr
models/task/fetch/mixins/fetcher.cr
models/task/fetch/thread.cr
models/task/mixins/singleton.cr
models/task/mixins/transfer.cr
models/task/monitor.cr
models/task/performance.cr
models/task/receive.cr
models/task/refresh_actor.cr
models/task/run_scripts.cr
models/task/terminate.cr
models/task/update_metrics.cr

Class Method Summary

Instance Method Summary

Instance methods inherited from module Ktistec::Model::Polymorphic

as_a(as _as : T.class) : T forall T as_a, type : String type, type=(type : String) type=

Macros inherited from module Ktistec::Model::Polymorphic

find(_id id, *, as _as)
find(*, as _as, **options)
find

Instance methods inherited from module Ktistec::Model::Common

created_at : Time created_at, created_at=(created_at : Time) created_at=, updated_at : Time updated_at, updated_at=(updated_at : Time) updated_at=

Instance methods inherited from module Ktistec::Model::InstanceMethods

==(other) ==, _run_validations _run_validations, _save_model(skip_validation = false) _save_model, _serialize_graph(nodes, association = nil, index = nil, skip_associated = false) _serialize_graph, assign(properties : Hash(String, Any), *, _strict : Bool = false) forall Any
assign(*, _strict : Bool = false, **properties)
assign
, changed!(*properties : Symbol) changed!, changed?
changed?(*properties : Symbol)
changed?
, clear!
clear!(*properties : Symbol)
clear!
, destroy destroy, destroyed? destroyed?, errors errors, hash(hasher) hash, inspect(io : IO) inspect, new_record? new_record?, reload! reload!, save(skip_validation = false, skip_associated = false) save, serialize_graph(skip_associated = false) serialize_graph, table_name table_name, to_h to_h, to_json(json : JSON::Builder) to_json, to_s(io : IO) to_s, update_property(property, value) update_property, valid?(skip_associated = false) valid?, validate(skip_associated = false) validate

Constructor methods inherited from module Ktistec::Model::InstanceMethods

new(properties : Hash(String, Any), *, _strict : Bool = false) forall Any
new(*, _strict : Bool = false, **properties)
new

Macros inherited from module Ktistec::Model::InstanceMethods

belongs_to(name, primary_key = id, foreign_key = nil, class_name = nil, inverse_of = nil) belongs_to, derived(decl, *, aliased_to) derived, has_many(name, primary_key = id, foreign_key = nil, class_name = nil, inverse_of = nil) has_many, has_one(name, primary_key = id, foreign_key = nil, class_name = nil, inverse_of = nil) has_one, validates(property, &block) validates

Instance methods inherited from module Ktistec::Model

id : Int64 | Nil id, id=(id : Int64 | Nil) id=

Class Method Detail

def self.clean_up_running_tasks #

[View source]
def self.destroy_old_tasks #

[View source]
def self.priority #

[View source]
def self.priority=(priority : Int32) #

[View source]
def self.scheduled(now = Time.utc, reserve = false) #

[View source]

Instance Method Detail

def backtrace : Array(String) | Nil #

[View source]
def backtrace=(backtrace : Array(String) | Nil) #

[View source]
def complete : Bool #

[View source]
def complete=(complete : Bool) #

[View source]
def gone? #

Indicates whether or not the task is gone.

Typically, this means that the task was saved but has been destroyed. Destroying a running task is a lightweight signal that the task should terminate itself.


[View source]
def last_attempt_at : Time | Nil #

[View source]
def last_attempt_at=(last_attempt_at : Time | Nil) #

[View source]
def next_attempt_at : Time | Nil #

[View source]
def next_attempt_at=(next_attempt_at : Time | Nil) #

[View source]
def past_due?(now = Time.utc) #

[View source]
def perform #

[View source]
def runnable? #

[View source]
def running : Bool #

[View source]
def running=(running : Bool) #

[View source]
def schedule(next_attempt_at : Time | Nil = nil) #

[View source]
def source_iri : String #

[View source]
def source_iri=(source_iri : String) #

[View source]
def subject_iri : String #

[View source]
def subject_iri=(subject_iri : String) #

[View source]