8156742544

Committed 05 Mar 2024 01:03PM UTC coverage: 69.889% (-0.3%) from 70.212%

Build # 8156742544

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #1054 from EsupPortail/develop

[DONE] Develop #3.5.1

Run Details

281 of 580 new or added lines in 23 files covered. (48.45%)

19 existing lines in 11 files now uncovered.

9911 of 14181 relevant lines covered (69.89%)

0.7 hits per line

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

0.0

/pod/video_encode_transcript/encoding_tasks.py

1	"""Esup-Pod encoding tasks."""
2
3	# pip3 install celery==5.2.7
4	# pip3 install webvtt-py
5	# pip3 install redis==4.5.4
6	from celery import Celery	×
7	import logging	×
NEW 8	import requests	×
9
10	# call local settings directly
11	# no need to load pod application to send statement
12	try:	×
13	from ..custom import settings_local	×
14	except ImportError:	×
15	from .. import settings as settings_local	×
16
NEW 17	EMAIL_HOST = getattr(settings_local, "EMAIL_HOST", "")	×
NEW 18	DEFAULT_FROM_EMAIL = getattr(settings_local, "DEFAULT_FROM_EMAIL", "")	×
NEW 19	ADMINS = getattr(settings_local, "ADMINS", ())	×
NEW 20	DEBUG = getattr(settings_local, "DEBUG", True)	×
NEW 21	TEST_REMOTE_ENCODE = getattr(settings_local, "TEST_REMOTE_ENCODE", False)	×
22
NEW 23	admins_email = [ad[1] for ad in ADMINS]	×
24
UNCOV 25	logger = logging.getLogger(__name__)	×
NEW 26	if DEBUG:	×
NEW 27	logger.setLevel(logging.DEBUG)	×
28
NEW 29	smtp_handler = logging.handlers.SMTPHandler(	×
30	mailhost=EMAIL_HOST,
31	fromaddr=DEFAULT_FROM_EMAIL,
32	toaddrs=admins_email,
33	subject="[POD ENCODING] Encoding Log Mail",
34	)
NEW 35	if not TEST_REMOTE_ENCODE:	×
NEW 36	logger.addHandler(smtp_handler)	×
37
38	ENCODING_TRANSCODING_CELERY_BROKER_URL = getattr(	×
39	settings_local, "ENCODING_TRANSCODING_CELERY_BROKER_URL", ""
40	)
NEW 41	POD_API_URL = getattr(settings_local, "POD_API_URL", "")	×
NEW 42	POD_API_TOKEN = getattr(settings_local, "POD_API_TOKEN", "")	×
43	encoding_app = Celery("encoding_tasks", broker=ENCODING_TRANSCODING_CELERY_BROKER_URL)	×
44	encoding_app.conf.task_routes = {	×
45	"pod.video_encode_transcript.encoding_tasks.*": {"queue": "encoding"}
46	}
47
48
49	# celery -A pod.video_encode_transcript.encoding_tasks worker -l INFO -Q encoding
50	@encoding_app.task	×
NEW 51	def start_encoding_task(	×
52	video_id, video_path, cut_start, cut_end, json_dressing, dressing_input
53	):
54	"""Start the encoding of the video."""
55	print("Start the encoding of the video")	×
56	from .Encoding_video import Encoding_video	×
57
UNCOV 58	print(video_id, video_path, cut_start, cut_end)	×
NEW 59	encoding_video = Encoding_video(	×
60	video_id, video_path, cut_start, cut_end, json_dressing, dressing_input
61	)
62	encoding_video.start_encode()	×
63	print("End of the encoding of the video")	×
NEW 64	Headers = {"Authorization": "Token %s" % POD_API_TOKEN}	×
NEW 65	url = POD_API_URL.strip("/") + "/store_remote_encoded_video/?id=%s" % video_id	×
NEW 66	data = {	×
67	"start": encoding_video.start,
68	"video_id": video_id,
69	"video_path": video_path,
70	"cut_start": cut_start,
71	"cut_end": cut_end,
72	"stop": encoding_video.stop,
73	"json_dressing": json_dressing,
74	"dressing_input": dressing_input,
75	}
NEW 76	try:	×
NEW 77	response = requests.post(url, json=data, headers=Headers)	×
NEW 78	if response.status_code != 200:	×
NEW 79	msg = "Calling store remote encoding error : {} {}".format(	×
80	response.status_code, response.reason
81	)
NEW 82	logger.error(msg + "\n" + str(response.content))	×
83	else:
NEW 84	logger.info("Call importing encoded task ok")	×
NEW 85	except (	×
86	requests.exceptions.HTTPError,
87	requests.exceptions.ConnectionError,
88	requests.exceptions.InvalidURL,
89	requests.exceptions.Timeout,
90	) as exception:
NEW 91	msg = "Exception: {}".format(type(exception).__name__)	×
NEW 92	msg += "\nException message: {}".format(exception)	×
NEW 93	logger.error(msg)	×

EsupPortail / Esup-Pod / 8156742544

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