Package index • taskqueue

All functions

db_clean(): Clean all tables and definition

db_connect(): Connect to postgreSQL db

db_disconnect(): Disconnect to db

db_init(): Initialize PostgreSQL database for taskqueue

db_sql(): A Wrapper function for DBI interface

.check_absolute_path(): Check absolute path for system

.check_linux_absolute_path(): Check absolute path for Linux

.check_windows_absolute_path(): Check absolute path for Windows

is_db_connect(): Test whether db can be connected

project_add(): Create project to database

project_delete(): Delete a project

project_get(): Get a project

project_list(): List all projects

project_reset(): Reset a project

project_resource_add(): Assign a resource to a project

project_resource_add_jobs(): Add a job to project/resource

project_resource_get(): Get resources of a project

project_resource_log_delete(): Delete all logs for a project resource

project_start(): Start a project

project_status(): Get project status

project_stop(): Stop a project

resource_add(): Add a new resource

resource_get(): Get a resource

resource_list(): Get all resource

shiny_app(): A shiny app to monitor project status

slurm_deploy(): Deploy taskqueue into slurm resources

table_exist(): Check whether a table is existed

task_add(): Add tasks into a project

task_clean(): Clear all tasks in a project

task_get(): Get tasks by status

task_reset(): Reset status of all tasks in a project to NULL

task_status(): Get task status in a project

taskqueue_options(): Set or get options for my package

taskqueue_reset(): Reset global options for pkg

tq_apply(): Apply a function with task queue

worker(): Execute a job on cluster

worker_slurm(): Create a worker on slurm cluster