"""Activity constants.""" from video import config from video.logic.activities.calculate_audio_stats import calculate_audio_stats from video.logic.activities.convert_thumbnails import convert_default_thumbnail_to_tiff # noqa from video.logic.activities.mediaconvert import create_mezzanines from video.logic.activities.mediaconvert import create_streamable_preview_and_thumbnails # noqa from video.logic.activities.convert_thumbnails import convert_thumbnails_to_tiffs # noqa from video.logic.activities.detect_black_intervals_at_beginning_and_end_of_video import detect_black_intervals_at_beginning_and_end_of_video # noqa from video.logic.activities.detect_max_volume import detect_max_volume from video.logic.activities.detect_silent_intervals_at_beginning_and_end_of_audio import detect_silent_intervals_at_beginning_and_end_of_audio # noqa from video.logic.activities.detect_video_location_and_dimensions_within_black_border import detect_video_location_and_dimensions_within_black_border # noqa from video.logic.activities.extract_metadata import extract_metadata from video.logic.activities.extract_metadata import extract_prores_mezzanine_metadata # noqa from video.logic.activities.get_product_metadata import get_product_metadata from video.logic.activities.mediaconvert import get_create_mezzanines_inputs from video.logic.activities.mediaconvert import is_create_mezzanines_done from video.logic.activities.mediaconvert import is_create_streamable_preview_and_thumbnails_done # noqa from video.logic.activities.transfer_from_s3_to_storage import is_ripper_mezzanine_processing_done # noqa from video.logic.activities.transfer_from_s3_to_storage import is_ripper_h264_processing_done # noqa from video.logic.activities.transfer_from_s3_to_storage import is_ripper_tiff_thumbnail_processing_done # noqa from video.logic.activities.transfer_from_browser_to_s3 import is_transfer_from_browser_to_s3_done # noqa from video.logic.activities.transfer_from_browser_to_s3 import log_transfer_completed # noqa from video.logic.activities.transfer_from_browser_to_s3 import log_transfer_timed_out # noqa from video.logic.activities.transfer_from_s3_to_storage import transfer_tiff_thumbnail_from_s3_to_ripper # noqa from video.logic.activities.transfer_from_s3_to_storage import transfer_prores_from_s3_to_ripper # noqa from video.logic.activities.transfer_from_s3_to_storage import transfer_h264_from_s3_to_ripper # noqa from video.logic.activities.transfer_from_s3_to_storage import transfer_h264_from_s3_to_ripper_storage # noqa from video.logic.activities.transfer_from_browser_to_s3 import transfer_from_browser_to_s3 # noqa from video.logic.activities.transfer_from_cloud_to_s3 import transfer_from_google_drive_to_s3 # noqa from video.logic.activities.transfer_from_cloud_to_s3 import transfer_from_dropbox_to_s3 # noqa from video.logic.activities.transfer_from_s3_to_s3 import transfer_from_s3_to_s3 # noqa from video.logic.activities.validate_analysis import validate_analysis from video.logic.activities.validate_metadata import validate_metadata from video.logic.activities.workflow import end_workflow from video.logic.activities.workflow import start_workflow from video.logic.activities.write_thumbnail_locations_to_video_asset_table import write_thumbnail_locations_to_video_asset_table # noqa from video.logic.activities.write_mezz_video_locations_to_video_asset_table import write_mezz_video_locations_to_video_asset_table # noqa from video.logic.activities.mark_video_product_as_approved import mark_video_product_as_approved # noqa ACTIVITY_PREFIX = '{env}_daemon_video'.format(env=config.ENVIRONMENT) ACTIVITY_NAME_TEMPLATE = '{prefix}_{handler}' ACTIVITIES_TO_HANDLERS = { ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=start_workflow.__name__, ): start_workflow, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=end_workflow.__name__, ): end_workflow, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_from_browser_to_s3.__name__, ): transfer_from_browser_to_s3, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=is_transfer_from_browser_to_s3_done.__name__, ): is_transfer_from_browser_to_s3_done, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=log_transfer_completed.__name__, ): log_transfer_completed, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=log_transfer_timed_out.__name__, ): log_transfer_timed_out, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_from_google_drive_to_s3.__name__, ): transfer_from_google_drive_to_s3, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_from_dropbox_to_s3.__name__, ): transfer_from_dropbox_to_s3, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_from_s3_to_s3.__name__, ): transfer_from_s3_to_s3, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=detect_black_intervals_at_beginning_and_end_of_video.__name__, ): detect_black_intervals_at_beginning_and_end_of_video, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=detect_silent_intervals_at_beginning_and_end_of_audio.__name__, ): detect_silent_intervals_at_beginning_and_end_of_audio, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=extract_metadata.__name__, ): extract_metadata, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=extract_prores_mezzanine_metadata.__name__, ): extract_prores_mezzanine_metadata, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=detect_video_location_and_dimensions_within_black_border.__name__, # noqa ): detect_video_location_and_dimensions_within_black_border, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=detect_max_volume.__name__, ): detect_max_volume, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=calculate_audio_stats.__name__, ): calculate_audio_stats, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=validate_metadata.__name__, ): validate_metadata, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=validate_analysis.__name__, ): validate_analysis, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=create_streamable_preview_and_thumbnails.__name__, ): create_streamable_preview_and_thumbnails, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=is_create_streamable_preview_and_thumbnails_done.__name__, ): is_create_streamable_preview_and_thumbnails_done, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=get_create_mezzanines_inputs.__name__, ): get_create_mezzanines_inputs, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=create_mezzanines.__name__, ): create_mezzanines, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=is_create_mezzanines_done.__name__, ): is_create_mezzanines_done, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=write_thumbnail_locations_to_video_asset_table.__name__, ): write_thumbnail_locations_to_video_asset_table, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=convert_thumbnails_to_tiffs.__name__, ): convert_thumbnails_to_tiffs, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=end_workflow.__name__, ): end_workflow, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=get_product_metadata.__name__, ): get_product_metadata, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=convert_default_thumbnail_to_tiff.__name__, ): convert_default_thumbnail_to_tiff, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=is_ripper_mezzanine_processing_done.__name__, ): is_ripper_mezzanine_processing_done, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=is_ripper_h264_processing_done.__name__, ): is_ripper_h264_processing_done, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=is_ripper_tiff_thumbnail_processing_done.__name__, ): is_ripper_tiff_thumbnail_processing_done, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=write_mezz_video_locations_to_video_asset_table.__name__, ): write_mezz_video_locations_to_video_asset_table, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=mark_video_product_as_approved.__name__, ): mark_video_product_as_approved, } ON_PREM_FILE_TRANSFER_ACTIVITIES_TO_HANDLERS = { ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_prores_from_s3_to_ripper.__name__, ): transfer_prores_from_s3_to_ripper, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_h264_from_s3_to_ripper.__name__ ): transfer_h264_from_s3_to_ripper, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_h264_from_s3_to_ripper_storage.__name__ ): transfer_h264_from_s3_to_ripper_storage, ACTIVITY_NAME_TEMPLATE.format( prefix=ACTIVITY_PREFIX, handler=transfer_tiff_thumbnail_from_s3_to_ripper.__name__, ): transfer_tiff_thumbnail_from_s3_to_ripper, } if config.IS_ON_PREM_INSTANCE: ACTIVITIES_TO_HANDLERS = ON_PREM_FILE_TRANSFER_ACTIVITIES_TO_HANDLERS