Compare commits

13 Commits
Author SHA1 Message Date
brb c19fc58a25 deleted unused code 2023-09-04 14:43:19 +02:00
brb bd5dc8fbc4 changed function to execute commands from runner script 2023-07-07 09:46:12 +02:00
brb f4a81b4b9b added and commented out code for passing through gpu 2023-07-07 09:45:45 +02:00
brb 477389d353 updated script 2023-07-06 17:34:08 +02:00
brb 90a44e8b6e updated running method 2023-07-06 17:32:41 +02:00
brb 36d2233567 updated exception handling when running commands from runner script 2023-07-06 17:30:40 +02:00
brb 2fc979a845 updated to run as user instead of root 2023-07-06 17:28:38 +02:00
brb 7218004f2f updated to run actual function 2023-07-06 17:22:21 +02:00
brb 75fd57391d added pip install requirements 2023-07-06 17:22:09 +02:00
brb a82e0a8f10 fixed logging bug 2023-07-06 16:44:49 +02:00
brb d1864c7030 added logging 2023-07-06 16:44:37 +02:00
brb 43e4b9788a updated to handle default and custom branch names 2023-07-06 16:42:54 +02:00
brb 84b409356b added detection of branch name 2023-07-06 16:07:27 +02:00
5 changed files with 55 additions and 16 deletions
+13 -4
View File
@@ -24,10 +24,12 @@ RUN pip wheel --no-cache-dir --no-deps --wheel-dir /usr/src/app/wheels -r requir
# pull official base image
FROM dvcorg/cml:0-dvc2-base1-gpu
# create app home
ENV APP_HOME = /home/app
RUN mkdir -p $APP_HOME
WORKDIR $APP_HOME
# create home directory and app user
RUN mkdir -p /home/app && \
addgroup --system app && \
adduser --system --group app
# add folder to store repo in
RUN mkdir -p /home/app/repo
# install packages from builder
@@ -36,7 +38,14 @@ COPY --from=builder /usr/src/app/requirements.txt requirements.txt
RUN pip install --no-cache /wheels/*
# copy in files
WORKDIR /home/app
COPY ./code .
# change ownership to app user
RUN chown -R app:app /home/app
# change to the app user
USER app
# start execution
ENTRYPOINT [ "python", "main.py" ]
+32 -9
View File
@@ -39,18 +39,18 @@ async def test(request: Request):
@app.post('/event')
def handle_event(request: GiteaRequest):
""" Handle event from webhook. """
# stop early if asked
# extract information
commit_msg = request.head_commit['message']
repo_url = request.repository['clone_url']
branch_name = request.ref.split('/')[-1]
# stop early if asked
if commit_msg.lower().startswith('[skip ci]'):
raise HTTPException(
status_code=200,
detail='skipping ci'
)
# clone repository
repo_url = request.repository['clone_url']
logging.info('cloning repository: {repo_url}')
local_repo_dir = clone_repository(repo_url)
logging.info(f'local_repo_dir: {local_repo_dir}')
# locate runner script
runner_script_path = local_repo_dir / 'runner_script.yml'
if not runner_script_path.exists():
@@ -58,17 +58,40 @@ def handle_event(request: GiteaRequest):
status_code=200,
detail="no runner_script.yml in repository root"
)
# load runner commands
# load runner script
runner_script = load_runner_script(path=runner_script_path)
for pipeline_name, pipeline_step in runner_script.pipelines.items():
print(pipeline_name)
print(pipeline_step)
# determine pipeline to run
if branch_name not in runner_script.pipelines.keys():
# get default pipeline
if 'default' not in runner_script.pipelines.keys():
raise HTTPException(
status_code=404,
detail='no pipelines defined in runner_script.yml'
)
pipeline = runner_script.pipelines['default']
else:
# get custom pipeline
pipeline = runner_script.pipelines[branch_name]
logging.info(f'running pipeline {pipeline.name}')
# TODO: create virtualenv?
# install requirements
assert pipeline.requirements is not None
requirements_path = local_repo_dir / pipeline.requirements
os.system(f'pip install -r {requirements_path}')
for cmd in pipeline.script:
try:
os.system(cmd)
except Exception as e:
raise HTTPException(
status_code=503,
detail=f'failed running {cmd}: {e}'
)
# send response
raise HTTPException(
status_code=202,
detail='received task'
)
# consider to include link to page that show progress
if __name__ == '__main__':
load_dotenv('dev.env')
+1
View File
@@ -28,5 +28,6 @@ def load_runner_script(path: Path) -> RunnerScript:
with open(path, 'r') as fh:
script = yaml.safe_load(fh)
runner_script = RunnerScript.parse_obj(script)
logging.debug('finished')
return runner_script
+7
View File
@@ -11,3 +11,10 @@ services:
- LISTEN_IP=0.0.0.0
- LISTEN_PORT=8000
- REPO_DIR=/home/app/repo/
# deploy:
# resources:
# reservations:
# devices:
# - driver: nvidia
# device_ids: ['0']
# capabilities: [gpu]
+1 -2
View File
@@ -4,8 +4,7 @@ definitions:
name: test
requirements: req-prod.txt
script:
- command arg1 arg2
- command2 arg1 arg2
- nvidia-smi
pipelines:
default: