taskqueue0.2.0 package

Task Queue for Parallel Computing Based on PostgreSQL

db_clean

Clean All Tables and Definitions from Database

db_connect

Connect to PostgreSQL Database

db_disconnect

Disconnect from PostgreSQL Database

db_init

Initialize PostgreSQL Database for taskqueue

db_sql

A Wrapper function for DBI interface

dot-check_absolute_path

Check absolute path for system

dot-check_linux_absolute_path

Check absolute path for Linux

dot-check_windows_absolute_path

Check absolute path for Windows

is_db_connect

Test Database Connection

project_add

Create a New Project

project_delete

Delete a Project

project_get

Get Project Information

project_list

List All Projects

project_reset

Reset a Project

project_resource_add_jobs

Manage SLURM Job List for Project Resource

project_resource_add

Assign a Resource to a Project

project_resource_get

Get resources of a project

project_resource_log_delete

Delete Log Files for a Project Resource

project_start

Start a Project

project_status

Display Project Status

project_stop

Stop a Project

resource_add

Add a New Computing Resource

resource_get

Get Information for a Specific Resource

resource_list

List All Computing Resources

shiny_app

Launch Shiny App for Monitoring Projects

table_exist

Check whether a table is existed

task_add

Add Tasks to a Project

task_clean

Remove All Tasks from a Project

task_get

Get Detailed Task Information

task_reset

Reset Task Status to Idle

task_status

Get Task Status Summary

taskqueue_options

Set or Get taskqueue Options

taskqueue_reset

Reset taskqueue Options to Defaults

tq_apply

Apply a Function with Task Queue (Simplified Workflow)

worker_slurm

Create a worker on slurm cluster

worker

Execute Tasks as a Worker

Implements a task queue system for asynchronous parallel computing using 'PostgreSQL' <https://www.postgresql.org/> as a backend. Designed for embarrassingly parallel problems where tasks do not communicate with each other. Dynamically distributes tasks to workers, handles uneven load balancing, and allows new workers to join at any time. Particularly useful for running large numbers of independent tasks on high-performance computing (HPC) clusters with 'SLURM' <https://slurm.schedmd.com/> job schedulers.

  • Maintainer: Bangyou Zheng
  • License: MIT + file LICENSE
  • Last published: 2025-12-03