TaskAPI for HTCondor

RESTful API for HTCondor HPC job scheduler. Allows HTCondor job submission, monitoring, and fetching job outputs. A background thread ensures that task state changes are recorded (and kept up-to-date) in a local SQLite database.

Update from Flask (marshmallow) to FastAPI (Pydantic V2)

This is a FastAPI app that reproduces the spec and functionality the earlier Flask-based app. Currently, it uses a combination of older models (marshmallow+SQLAlchemy.orm) and Pydantic V2 models (used for serialization/deserialization of HTTP payloads).

Installation

Install dependencies

pip install fastapi hypercorn htcondor marshmallow sqlalchemy

Install the STAPI app

Using the HTTP link of the repository (github.com/myorg/simple-task-api-htc.git):

pip install git+https://[url]

Or using the SSH link:

Note

When using the SSH link in pip install, remember to replace : with /. For example, the SSH link [email protected]:myorg/simple-task-api-htc.git should be used as pip install git+ssh://[email protected]/myorg/simple-task-api-htc.git.

pip install git+ssh://[url]

Usage

Prepare the instance dir

Navigate to the instance directory (where instance-related files will be created).

Under ./htc-log, create an empty file for condor logs:

mkdir htc-log && touch htc-log/0.log

Create an empty subdir for tasks:

mkdir taskroot

Run the app

Run:

simple-task-api-htc

Output:

Running on http://127.0.0.1:8080 (CTRL + C to quit)

The API would be available under the prefix /api, and since this is a FastAPI app, SwaggerUI with the auto-generated OpenAPI spec can be accessed at: http://127.0.0.1:8080/docs.

Example Job Submission

Submit a new task

Requeset

curl -X 'POST' \
  'http://localhost:8080/api/tasks' \
  -H 'Content-Type: application/json' \
  -d '{
  "id": "41a694e0-5b66-4e79-9abd-7ea9d351f0e6",
  "subParams": {
    "executable": "/home/condoruser/test-retry-02/myscript.sh",
    "initialdir": "/home/condoruser/testlog",
    "arguments": "5 0"
  }
}'

Response

{
  "id": "41a694e0-5b66-4e79-9abd-7ea9d351f0e6",
  # ...
}

Check task status

Request

curl -X 'GET' \
  'http://localhost:8080/api/tasks/41a694e0-5b66-4e79-9abd-7ea9d351f0e6'

Response

{
  "id": "41a694e0-5b66-4e79-9abd-7ea9d351f0e6",
  "creationDate": "2023-11-06T19:08:54",
  "subParams": {
    "executable": "/home/condoruser/test-retry-02/myscript.sh",
    "initialdir": "/home/condoruser/testlog",
    "arguments": "5 0"
  },
  "state": 2,
  "stateDate": "2023-11-06T19:09:15.633848",
  "retriesLeft": 1,
  "clusterId": 102,
  "procId": null,
  "expirationDate": null,
  "latestSubId": null
}