You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

41 lines
1.0 KiB

#!/usr/bin/env python3
Log jobs to be processed by the job processor.
import os, json, pathlib, sys, time
from settings import MINIQ_ROOT
# Sub-dir for queued jobs with params
QUEUED_JOBS = os.path.join(MINIQ_ROOT, 'queue')
# Sub-dir for job definition files
JOB_DEFS = os.path.join(MINIQ_ROOT, 'jobs')
# Make sure we specified the job type
if len(sys.argv) < 2:
print('Missing name of job to enqueue.')
# Get the job type and any arguments from the CLI
_, job_name, *args = sys.argv
data = {
'job': job_name,
'arguments': args,
# Make sure the job type is valid
if not os.path.exists(os.path.join(JOB_DEFS, data['job'] + '.job')):
print('Invalid job type.')
# This is the name of the file that will be written to the queued jobs
file_name = str(int(time.time() * 100000)) + '.' + str(job_name) + '.json'
# Write the job data to the queue file
with open(os.path.join(QUEUED_JOBS, file_name), 'w') as out_file:
print('Queued ' + job_name + ' as ' + file_name)