Commit bdc457a4 by Gregory Martin

Change HEAL for legacy video encodes.

parent 2f0d8d4b
......@@ -55,10 +55,20 @@ class VedaHeal(object):
hours=HEAL_END
)
)
for v in self.video_query:
LOGGER.info('[HEAL] {studio_id} | {video_id}: Determining Missing Encodes'.format(
studio_id=v.studio_id,
video_id=v.edx_id,
))
self.send_encodes()
def send_encodes(self):
"""
Unified function to enqueue videos with missing encodes
Ingest/HEAL both call this function
"""
# TODO: Refactor to common location
for v in self.video_query:
encode_list = self.determine_fault(video_object=v)
# Using the 'Video Proto' Model
......
......@@ -237,10 +237,11 @@ class VALAPICall(object):
"""
# Defend against old/deprecated encodes
try:
self.auth_dict['val_profile_dict'][self.encode_profile]
except KeyError:
return
if self.encode_profile:
try:
self.auth_dict['val_profile_dict'][self.encode_profile]
except KeyError:
return
if self.endpoint_url:
for p in self.auth_dict['val_profile_dict'][self.encode_profile]:
......@@ -270,7 +271,7 @@ class VALAPICall(object):
try:
self.auth_dict['val_profile_dict'][final.encode_profile.product_spec]
except KeyError:
return
continue
for p in self.auth_dict['val_profile_dict'][final.encode_profile.product_spec]:
test_list.append(dict(
url=str(final.encode_url),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment