5462629459

pending completion

Build # 5462629459

Build Type

Pull #899

github

Committed by

web-flow

Commit Message

Merge e759dacb6 into c94f0e331

Pull Request Pull Request #899: [DONE] Ptitloup/feature new encoding

Run Details

400 of 400 new or added lines in 14 files covered. (100.0%)

8968 of 12675 relevant lines covered (70.75%)

0.71 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pod/video_encode_transcript/importing_tasks.py

from celery import Celery
try:
    from ..custom import settings_local
except ImportError:
    from .. import settings as settings_local
import logging
logger = logging.getLogger(__name__)

ENCODING_TRANSCODING_CELERY_BROKER_URL = getattr(
    settings_local,
    "ENCODING_TRANSCODING_CELERY_BROKER_URL",
    ""
)

importing_app = Celery(
    "importing_tasks",
    broker=ENCODING_TRANSCODING_CELERY_BROKER_URL
)
importing_app.conf.task_routes = {
    "pod.video_encode_transcript.importing_tasks.*": {"queue": "importing"}
}


# celery -A pod.video_encode_transcript.importing_tasks worker -l INFO -Q importing
@importing_app.task
def start_importing_task(start, video_id, video_path, cut_start, cut_end, stop):
    """Start the import of the encoding of the video."""
    print("Start the importing of the video: %s" % video_id)
    from .Encoding_video_model import Encoding_video_model
    from .encode import store_encoding_info, end_of_encoding
    encoding_video = Encoding_video_model(video_id, video_path, cut_start, cut_end)
    encoding_video.start = start
    encoding_video.stop = stop

    final_video = store_encoding_info(video_id, encoding_video)
    end_of_encoding(final_video)

1	from celery import Celery	×
2	try:	×
3	from ..custom import settings_local	×
4	except ImportError:	×
5	from .. import settings as settings_local	×
6	import logging	×
7	logger = logging.getLogger(__name__)	×
8
9	ENCODING_TRANSCODING_CELERY_BROKER_URL = getattr(	×
10	settings_local,
11	"ENCODING_TRANSCODING_CELERY_BROKER_URL",
12	""
13	)
14
15	importing_app = Celery(	×
16	"importing_tasks",
17	broker=ENCODING_TRANSCODING_CELERY_BROKER_URL
18	)
19	importing_app.conf.task_routes = {	×
20	"pod.video_encode_transcript.importing_tasks.*": {"queue": "importing"}
21	}
22
23
24	# celery -A pod.video_encode_transcript.importing_tasks worker -l INFO -Q importing
25	@importing_app.task	×
26	def start_importing_task(start, video_id, video_path, cut_start, cut_end, stop):	×
27	"""Start the import of the encoding of the video."""
28	print("Start the importing of the video: %s" % video_id)	×
29	from .Encoding_video_model import Encoding_video_model	×
30	from .encode import store_encoding_info, end_of_encoding	×
31	encoding_video = Encoding_video_model(video_id, video_path, cut_start, cut_end)	×
32	encoding_video.start = start	×
33	encoding_video.stop = stop	×
34
35	final_video = store_encoding_info(video_id, encoding_video)	×
36	end_of_encoding(final_video)	×

EsupPortail / Esup-Pod / 5462629459

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous