Module: Tasker

Defined in:
lib/tasker.rb,
lib/tasker/types.rb,
lib/tasker/engine.rb,
lib/tasker/errors.rb,
lib/tasker/events.rb,
lib/tasker/railtie.rb,
lib/tasker/version.rb,
lib/tasker/registry.rb,
lib/tasker/constants.rb,
lib/tasker/functions.rb,
lib/tasker/telemetry.rb,
app/models/tasker/task.rb,
lib/tasker/task_builder.rb,
lib/tasker/task_handler.rb,
lib/tasker/authorization.rb,
lib/tasker/configuration.rb,
lib/tasker/orchestration.rb,
lib/tasker/state_machine.rb,
lib/tasker/cache_strategy.rb,
lib/tasker/events/catalog.rb,
lib/tasker/handler_factory.rb,
lib/tasker/events/publisher.rb,
lib/tasker/step_handler/api.rb,
app/models/tasker/named_step.rb,
app/models/tasker/named_task.rb,
lib/tasker/identity_strategy.rb,
lib/tasker/step_handler/base.rb,
lib/tasker/types/auth_config.rb,
lib/tasker/cache_capabilities.rb,
lib/tasker/types/cache_config.rb,
lib/tasker/types/task_request.rb,
lib/tasker/types/engine_config.rb,
lib/tasker/types/health_config.rb,
lib/tasker/types/step_sequence.rb,
lib/tasker/types/step_template.rb,
app/jobs/tasker/application_job.rb,
app/jobs/tasker/task_runner_job.rb,
app/models/tasker/workflow_step.rb,
lib/tasker/authorization/errors.rb,
lib/tasker/types/backoff_config.rb,
app/controllers/tasker/page_sort.rb,
app/models/tasker/task_namespace.rb,
lib/tasker/authentication/errors.rb,
lib/tasker/concerns/authorizable.rb,
lib/tasker/health/status_checker.rb,
lib/tasker/telemetry/log_backend.rb,
lib/tasker/types/database_config.rb,
app/graphql/tasker/graph_ql_types.rb,
app/models/tasker/annotation_type.rb,
app/models/tasker/task_annotation.rb,
app/models/tasker/task_transition.rb,
lib/tasker/events/custom_registry.rb,
lib/tasker/registry/base_registry.rb,
lib/tasker/telemetry/event_router.rb,
lib/tasker/telemetry/metric_types.rb,
lib/tasker/types/dependency_graph.rb,
lib/tasker/types/execution_config.rb,
lib/tasker/types/telemetry_config.rb,
app/graphql/tasker/queries/helpers.rb,
app/jobs/tasker/metrics_export_job.rb,
app/models/tasker/dependent_system.rb,
lib/tasker/task_handler/step_group.rb,
lib/tasker/telemetry/event_mapping.rb,
lib/tasker/telemetry/trace_backend.rb,
app/graphql/tasker/queries/one_step.rb,
app/graphql/tasker/queries/one_task.rb,
lib/tasker/authentication/interface.rb,
lib/tasker/concerns/authenticatable.rb,
lib/tasker/concerns/event_publisher.rb,
lib/tasker/events/definition_loader.rb,
lib/tasker/health/readiness_checker.rb,
lib/tasker/registry/event_publisher.rb,
app/graphql/tasker/queries/all_tasks.rb,
app/models/tasker/application_record.rb,
app/models/tasker/workflow_step_edge.rb,
lib/tasker/constants/registry_events.rb,
lib/tasker/orchestration/coordinator.rb,
lib/tasker/telemetry/metrics_backend.rb,
lib/tasker/telemetry/plugin_registry.rb,
app/graphql/tasker/queries/base_query.rb,
app/services/tasker/analytics_service.rb,
lib/tasker/authentication/coordinator.rb,
lib/tasker/events/subscription_loader.rb,
lib/tasker/functions/function_wrapper.rb,
lib/tasker/task_handler/class_methods.rb,
app/graphql/tasker/tasker_rails_schema.rb,
app/serializers/tasker/task_serializer.rb,
lib/generators/tasker/events_generator.rb,
lib/tasker/concerns/state_machine_base.rb,
lib/tasker/concerns/structured_logging.rb,
lib/tasker/constants/event_definitions.rb,
lib/tasker/orchestration/step_executor.rb,
app/controllers/tasker/tasks_controller.rb,
app/models/tasker/step_dag_relationship.rb,
app/models/tasker/step_readiness_status.rb,
lib/tasker/events/event_payload_builder.rb,
lib/tasker/orchestration/task_finalizer.rb,
lib/tasker/registry/interface_validator.rb,
lib/tasker/registry/subscriber_registry.rb,
lib/tasker/telemetry/export_coordinator.rb,
app/controllers/tasker/health_controller.rb,
app/graphql/tasker/mutations/cancel_step.rb,
app/graphql/tasker/mutations/cancel_task.rb,
app/graphql/tasker/mutations/create_task.rb,
app/graphql/tasker/mutations/update_step.rb,
app/graphql/tasker/mutations/update_task.rb,
app/models/tasker/named_tasks_named_step.rb,
app/models/tasker/task_execution_context.rb,
lib/tasker/orchestration/task_reenqueuer.rb,
lib/tasker/registry/statistics_collector.rb,
lib/tasker/task_handler/instance_methods.rb,
lib/tasker/telemetry/prometheus_exporter.rb,
lib/tasker/types/dependency_graph_config.rb,
app/controllers/tasker/graphql_controller.rb,
app/controllers/tasker/metrics_controller.rb,
app/serializers/tasker/handler_serializer.rb,
lib/tasker/authorization/base_coordinator.rb,
lib/tasker/orchestration/task_initializer.rb,
lib/tasker/telemetry/events/export_events.rb,
lib/tasker/telemetry/plugins/csv_exporter.rb,
app/controllers/tasker/handlers_controller.rb,
app/graphql/tasker/mutations/base_mutation.rb,
app/graphql/tasker/queries/tasks_by_status.rb,
app/models/tasker/workflow_step_transition.rb,
lib/generators/tasker/subscriber_generator.rb,
lib/tasker/analysis/runtime_graph_analyzer.rb,
lib/tasker/authorization/resource_registry.rb,
lib/tasker/telemetry/plugins/base_exporter.rb,
lib/tasker/telemetry/plugins/json_exporter.rb,
app/controllers/tasker/analytics_controller.rb,
app/graphql/tasker/graph_ql_types/base_edge.rb,
app/graphql/tasker/graph_ql_types/base_enum.rb,
app/graphql/tasker/graph_ql_types/node_type.rb,
app/graphql/tasker/graph_ql_types/task_type.rb,
lib/tasker/analysis/template_graph_analyzer.rb,
lib/tasker/authorization/resource_constants.rb,
lib/tasker/concerns/controller_authorizable.rb,
lib/tasker/logging/correlation_id_generator.rb,
lib/tasker/orchestration/backoff_calculator.rb,
lib/tasker/orchestration/connection_builder.rb,
lib/tasker/orchestration/plugin_integration.rb,
lib/tasker/orchestration/response_processor.rb,
lib/tasker/state_machine/step_state_machine.rb,
lib/tasker/state_machine/task_state_machine.rb,
lib/tasker/telemetry/metrics_export_service.rb,
app/graphql/tasker/graph_ql_types/base_field.rb,
app/graphql/tasker/graph_ql_types/base_union.rb,
app/graphql/tasker/graph_ql_types/query_type.rb,
lib/generators/tasker/task_handler_generator.rb,
lib/tasker/authentication/none_authenticator.rb,
lib/tasker/orchestration/retry_header_parser.rb,
app/controllers/tasker/application_controller.rb,
app/graphql/tasker/graph_ql_types/base_object.rb,
app/graphql/tasker/graph_ql_types/base_scalar.rb,
app/models/tasker/dependent_system_object_map.rb,
lib/generators/tasker/authenticator_generator.rb,
lib/tasker/events/subscribers/base_subscriber.rb,
lib/tasker/orchestration/workflow_coordinator.rb,
app/graphql/tasker/queries/tasks_by_annotation.rb,
lib/tasker/orchestration/future_state_analyzer.rb,
lib/tasker/orchestration/step_sequence_factory.rb,
lib/tasker/orchestration/viable_step_discovery.rb,
lib/tasker/telemetry/intelligent_cache_manager.rb,
app/graphql/tasker/graph_ql_types/base_argument.rb,
app/graphql/tasker/graph_ql_types/mutation_type.rb,
app/graphql/tasker/queries/all_annotation_types.rb,
app/serializers/tasker/workflow_step_serializer.rb,
app/controllers/tasker/workflow_steps_controller.rb,
app/graphql/tasker/graph_ql_types/base_interface.rb,
app/graphql/tasker/graph_ql_types/task_interface.rb,
lib/tasker/concerns/idempotent_state_transitions.rb,
lib/tasker/events/subscribers/metrics_subscriber.rb,
app/graphql/tasker/graph_ql_types/annotation_type.rb,
app/graphql/tasker/graph_ql_types/base_connection.rb,
app/graphql/tasker/graph_ql_types/named_step_type.rb,
app/graphql/tasker/graph_ql_types/named_task_type.rb,
app/serializers/tasker/annotation_type_serializer.rb,
app/serializers/tasker/task_annotation_serializer.rb,
lib/tasker/functions/function_based_slowest_steps.rb,
lib/tasker/functions/function_based_slowest_tasks.rb,
lib/tasker/events/subscribers/telemetry_subscriber.rb,
app/graphql/tasker/graph_ql_types/base_input_object.rb,
app/graphql/tasker/graph_ql_types/workflow_step_type.rb,
lib/tasker/functions/function_based_analytics_metrics.rb,
lib/tasker/functions/function_based_dependency_levels.rb,
lib/tasker/orchestration/connection_pool_intelligence.rb,
app/graphql/tasker/graph_ql_types/task_annotation_type.rb,
app/graphql/tasker/graph_ql_types/dependent_system_type.rb,
lib/tasker/functions/function_based_system_health_counts.rb,
lib/generators/tasker/authorization_coordinator_generator.rb,
lib/tasker/functions/function_based_step_readiness_status.rb,
lib/tasker/functions/function_based_task_execution_context.rb,
app/graphql/tasker/graph_ql_types/named_tasks_named_step_type.rb,
app/graphql/tasker/graph_ql_types/dependent_system_object_map_type.rb

Overview

typed: false frozen_string_literal: true

Defined Under Namespace

Modules: Analysis, Authentication, Authorization, CacheCapabilities, Concerns, Constants, Events, Functions, Generators, GraphQLTypes, Health, Logging, Mutations, Orchestration, PageSort, Queries, Registry, StateMachine, StepHandler, TaskHandler, Telemetry, Types Classes: AnalyticsController, AnalyticsService, AnnotationType, AnnotationTypeSerializer, ApplicationController, ApplicationJob, ApplicationRecord, CacheStrategy, Configuration, ConfigurationError, ConfiguredTask, DependentSystem, DependentSystemObjectMap, DetectorRegistry, Engine, Error, EventsGenerator, GraphqlController, HandlerFactory, HandlerSerializer, HandlersController, HashIdentityStrategy, HealthController, IdentityStrategy, InvalidTaskHandlerConfig, MetricsController, MetricsExportJob, NamedStep, NamedTask, NamedTasksNamedStep, PermanentError, ProceduralError, Railtie, RetryableError, StepDagRelationship, StepReadinessStatus, Task, TaskAnnotation, TaskAnnotationSerializer, TaskBuilder, TaskExecutionContext, TaskNamespace, TaskRunnerJob, TaskSerializer, TaskTransition, TaskerRailsSchema, TasksController, WorkflowStep, WorkflowStepEdge, WorkflowStepSerializer, WorkflowStepTransition, WorkflowStepsController

Constant Summary collapse

VERSION = 
'0.1.0'
Version =

rubocop:disable Naming/ConstantName

'0.1.0'

Class Method Summary collapse

Class Method Details

.configuration {|Configuration| ... } ⇒ Tasker::Configuration

Accesses the global configuration for Tasker

Yields:

  • (Configuration) —

    The configuration instance if a block is given

Returns:



61
62
63
 
# File 'lib/tasker.rb', line 61

def self.configuration(&)
  Configuration.configuration(&)
end

.configure {|Configuration| ... } ⇒ Tasker::Configuration

Configure Tasker with a block

Yields:

  • (Configuration) —

    The configuration instance for setting options

Returns:



69
70
71
72
 
# File 'lib/tasker.rb', line 69

def self.configure
  yield(configuration) if block_given?
  configuration
end

.reset_configuration! ⇒ Tasker::Configuration

Resets the configuration to default values

Primarily used for testing to ensure a clean configuration state.

Returns:



79
80
81
 
# File 'lib/tasker.rb', line 79

def self.reset_configuration!
  Configuration.reset_configuration!
end