Compare commits

..

No commits in common. "c80f16c77af2ede1061cb619c022640dbc1d4caf" and "4913bf8d38e7dc14c0a3929659848af94ede6c18" have entirely different histories.

12 changed files with 25 additions and 33 deletions

View file

@ -61,6 +61,7 @@ apt-get install -y \
oxframe \
ffmpeg \
mkvtoolnix \
gpac \
imagemagick \
poppler-utils \
ipython3 \

View file

@ -15,7 +15,7 @@ ExecStart=/srv/pandora/bin/celery \
-Q encoding -n pandora-encoding \
--pidfile /run/pandora/encoding.pid \
-c $CONCURRENCY \
--max-tasks-per-child $MAX_TASKS_PER_CHILD \
--maxtasksperchild $MAX_TASKS_PER_CHILD \
-l $LOGLEVEL
ExecReload=/bin/kill -TERM $MAINPID

View file

@ -15,7 +15,7 @@ ExecStart=/srv/pandora/bin/celery \
-Q default,celery -n pandora-default \
--pidfile /run/pandora/tasks.pid \
-c $CONCURRENCY \
--max-tasks-per-child $MAX_TASKS_PER_CHILD \
--maxtasksperchild $MAX_TASKS_PER_CHILD \
-l $LOGLEVEL
ExecReload=/bin/kill -TERM $MAINPID

View file

@ -1,9 +1,11 @@
# -*- coding: utf-8 -*-
from datetime import datetime
from time import time, monotonic
from time import time
import celery.task.control
import kombu.five
from app.celery import app
from .models import File
@ -16,7 +18,7 @@ def parse_job(job):
'file': f.oshash
}
if job['time_start']:
start_time = datetime.fromtimestamp(time() - (monotonic() - job['time_start']))
start_time = datetime.fromtimestamp(time() - (kombu.five.monotonic() - job['time_start']))
r.update({
'started': start_time,
'running': (datetime.now() - start_time).total_seconds()
@ -28,7 +30,7 @@ def parse_job(job):
def status():
status = []
encoding_jobs = ('archive.tasks.extract_stream', 'archive.tasks.process_stream')
c = app.control.inspect()
c = celery.task.control.inspect()
for job in c.active(safe=True).get('celery@pandora-encoding', []):
if job['name'] in encoding_jobs:
status.append(parse_job(job))

View file

@ -5,12 +5,12 @@ import copy
from django.db import models
from django.utils import datetime_safe
import django.contrib.postgres.fields
from django.core.serializers.json import DjangoJSONEncoder
from ox.utils import json
class JSONField(models.JSONField):
class JSONField(django.contrib.postgres.fields.JSONField):
def __init__(self, *args, **kwargs):
if 'encoder' not in kwargs:

View file

@ -37,12 +37,12 @@ class NullsLastQuery(Query):
obj.nulls_last = self.nulls_last
return obj
def get_compiler(self, using=None, connection=None, elide_empty=True):
def get_compiler(self, using=None, connection=None):
if using is None and connection is None:
raise ValueError("Need either using or connection")
if using:
connection = connections[using]
return NullLastSQLCompiler(self, connection, using, elide_empty)
return NullLastSQLCompiler(self, connection, using)
class QuerySet(django.db.models.query.QuerySet):

View file

@ -8,11 +8,10 @@ from django.contrib.auth import get_user_model
from django.conf import settings
from django.db import models
from django.db.models import Q
import celery.task.control
import kombu.five
import ox
from app.celery import app
User = get_user_model()
def get_tasks(username):
@ -112,7 +111,7 @@ class Task(models.Model):
return False
def get_job(self):
c = app.control.inspect()
c = celery.task.control.inspect()
active = c.active(safe=True)
if active:
for queue in active:

View file

@ -1,10 +1,10 @@
Django==4.2.3
Django==3.0.10
simplejson
chardet
celery==5.3.1
django-celery-results==2.5.1
django-celery-beat==2.5.0
django-extensions==3.2.3
celery<5.0,>4.3
django-celery-results<2
django-celery-beat
django-extensions==2.2.9
libsass
django-compressor
django-sass-processor

View file

@ -516,12 +516,12 @@ pandora.ui.infoView = function(data, isMixed) {
}
$('<span>').html(formatKey(key)).appendTo($element);
Ox.EditableContent({
clickLink: pandora.clickLink,
editable: canEdit,
clickLink: pandora.clickLink,
format: function(value) {
return formatValue(key, value);
},
placeholder: formatLight(Ox._(isMixed[key] ? 'mixed' : 'unknown')),
placeholder: formatLight(Ox._( isMixed[key] ? 'mixed' : 'unknown')),
tooltip: canEdit ? pandora.getEditTooltip() : '',
value: getValue(key, data[key])
})
@ -542,7 +542,6 @@ pandora.ui.infoView = function(data, isMixed) {
});
$element.appendTo($text);
}
return $element;
}
function renderRemainingKeys() {

View file

@ -655,8 +655,8 @@ pandora.ui.infoView = function(data, isMixed) {
}
$('<span>').html(formatKey(key)).appendTo($element);
Ox.EditableContent({
clickLink: pandora.clickLink,
editable: canEdit,
clickLink: pandora.clickLink,
format: function(value) {
return formatValue(key, value);
},
@ -670,18 +670,10 @@ pandora.ui.infoView = function(data, isMixed) {
}
})
.appendTo($element);
if (isMixed[key] && Ox.contains(listKeys, key)) {
pandora.ui.addRemoveKeyDialog({
ids: ui.listSelection,
key: key,
section: ui.section
}).appendTo($element)
}
}
});
$element.appendTo($text);
}
return $element;
}
function toggleIconSize() {

View file

@ -305,8 +305,6 @@ if __name__ == "__main__":
run('./bin/pip', 'install', '-r', 'requirements.txt')
if old < 6500:
run('./bin/pip', 'install', '-r', 'requirements.txt')
if old <= 6517:
run('./bin/pip', 'install', '-r', 'requirements.txt')
else:
if len(sys.argv) == 1:
branch = get_branch()

View file

@ -121,6 +121,7 @@ apt-get install -y \
python3-elasticsearch \
ffmpeg \
mkvtoolnix \
gpac \
imagemagick \
poppler-utils \
ipython3 \