8017784387

Committed 23 Feb 2024 10:21AM UTC coverage: 70.319% (-0.2%) from 70.49%

Build # 8017784387

Build Type

Pull #1056

github

Committed by

web-flow

Commit Message

Merge 1c868b2a3 into f8e2c5049

Pull Request Pull Request #1056: [WIP] Fix remote encoding and other stuff

Run Details

46 of 156 new or added lines in 9 files covered. (29.49%)

6 existing lines in 6 files now uncovered.

9884 of 14056 relevant lines covered (70.32%)

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)	×
21
NEW 22	admins_email = [ad[1] for ad in ADMINS]	×
23
UNCOV 24	logger = logging.getLogger(__name__)	×
NEW 25	if DEBUG:	×
NEW 26	logger.setLevel(logging.DEBUG)	×
27
NEW 28	smtp_handler = logging.handlers.SMTPHandler(	×
29	mailhost=EMAIL_HOST,
30	fromaddr=DEFAULT_FROM_EMAIL,
31	toaddrs=admins_email,
32	subject='[POD ENCODING] Encoding Log Mail'
33	)
NEW 34	logger.addHandler(smtp_handler)	×
35
36	ENCODING_TRANSCODING_CELERY_BROKER_URL = getattr(	×
37	settings_local, "ENCODING_TRANSCODING_CELERY_BROKER_URL", ""
38	)
NEW 39	POD_API_URL = getattr(	×
40	settings_local, "POD_API_URL", ""
41	)
NEW 42	POD_API_TOKEN = getattr(	×
43	settings_local, "POD_API_TOKEN", ""
44	)
45	encoding_app = Celery("encoding_tasks", broker=ENCODING_TRANSCODING_CELERY_BROKER_URL)	×
46	encoding_app.conf.task_routes = {	×
47	"pod.video_encode_transcript.encoding_tasks.*": {"queue": "encoding"}
48	}
49
50
51	# celery -A pod.video_encode_transcript.encoding_tasks worker -l INFO -Q encoding
52	@encoding_app.task	×
NEW 53	def start_encoding_task(	×
54	video_id, video_path, cut_start, cut_end, json_dressing, dressing_input
55	):
56	"""Start the encoding of the video."""
57	print("Start the encoding of the video")	×
58	from .Encoding_video import Encoding_video	×
59	print(video_id, video_path, cut_start, cut_end)	×
NEW 60	encoding_video = Encoding_video(	×
61	video_id, video_path, cut_start, cut_end, json_dressing, dressing_input
62	)
63	encoding_video.start_encode()	×
64	print("End of the encoding of the video")	×
NEW 65	Headers = {"Authorization" : "Token %s" % POD_API_TOKEN}	×
NEW 66	url = POD_API_URL.strip("/") + "/store_remote_encoded_video/?id=%s" % video_id	×
NEW 67	data = {	×
68	"start": encoding_video.start,
69	"video_id": video_id,
70	"video_path": video_path,
71	"cut_start": cut_start,
72	"cut_end": cut_end,
73	"stop": encoding_video.stop,
74	"json_dressing": json_dressing,
75	"dressing_input": dressing_input
76	}
NEW 77	try:	×
NEW 78	response = requests.post(url, json=data, headers=Headers)	×
NEW 79	if response.status_code != 200:	×
NEW 80	msg = "Calling store remote encoding error : {} {}".format(	×
81	response.status_code,
82	response.reason
83	)
NEW 84	logger.error(msg + "\n" + str(response.content))	×
85	else:
NEW 86	logger.info("Call importing encoded task ok")	×
NEW 87	except (	×
88	requests.exceptions.HTTPError,
89	requests.exceptions.ConnectionError,
90	requests.exceptions.InvalidURL,
91	requests.exceptions.Timeout
92	) as exception:
NEW 93	msg = "Exception: {}".format(type(exception).__name__)	×
NEW 94	msg += "\nException message: {}".format(exception)	×
NEW 95	logger.error(msg)	×

EsupPortail / Esup-Pod / 8017784387

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