MCPcopy Index your code
hub / github.com/diffgram/diffgram / enqueue_packet

Function enqueue_packet

shared/ingest/packet.py:22–133  ·  view source on GitHub ↗

Creates Input() object and enqueues it for media processing Returns Input() object that was created :param packet_data: :return:

(project_string_id,
                   session,
                   media_url = None,
                   media_type = None,
                   file_id = None,
                   file_name = None,
                   job_id = None,
                   batch_id = None,
                   directory_id = None,
                   source_directory_id = None,
                   instance_list = None,
                   video_split_duration = None,
                   frame_packet_map = None,
                   remove_link = None,
                   add_link = None,
                   copy_instance_list = None,
                   commit_input = False,
                   task_id = None,
                   video_parent_length = None,
                   type = None,
                   task_action = None,
                   external_map_id = None,
                   original_filename = None,
                   external_map_action = None,
                   enqueue_immediately = False,
                   action_trigger_id = None,
                   workflow_trigger_id = None,
                   text_data = None,
                   image_metadata = {},
                   file_metadata = {},
                   mode = None,
                   allow_duplicates = False,
                   auto_correct_instances_from_image_metadata = False,
                   extract_labels_from_batch = False,
                   member = None)

Source from the content-addressed store, hash-verified

20
21
22def enqueue_packet(project_string_id,
23 session,
24 media_url = None,
25 media_type = None,
26 file_id = None,
27 file_name = None,
28 job_id = None,
29 batch_id = None,
30 directory_id = None,
31 source_directory_id = None,
32 instance_list = None,
33 video_split_duration = None,
34 frame_packet_map = None,
35 remove_link = None,
36 add_link = None,
37 copy_instance_list = None,
38 commit_input = False,
39 task_id = None,
40 video_parent_length = None,
41 type = None,
42 task_action = None,
43 external_map_id = None,
44 original_filename = None,
45 external_map_action = None,
46 enqueue_immediately = False,
47 action_trigger_id = None,
48 workflow_trigger_id = None,
49 text_data = None,
50 image_metadata = {},
51 file_metadata = {},
52 mode = None,
53 allow_duplicates = False,
54 auto_correct_instances_from_image_metadata = False,
55 extract_labels_from_batch = False,
56 member = None):
57 """
58 Creates Input() object and enqueues it for media processing
59 Returns Input() object that was created
60 :param packet_data:
61 :return:
62 """
63 diffgram_input = Input()
64 project = Project.get(session, project_string_id)
65 diffgram_input.file_id = file_id
66 diffgram_input.action_trigger_id = action_trigger_id
67 diffgram_input.workflow_trigger_id = workflow_trigger_id
68 diffgram_input.text_data = text_data
69 diffgram_input.image_metadata = image_metadata
70 diffgram_input.file_metadata = file_metadata
71 diffgram_input.auto_correct_instances_from_image_metadata = auto_correct_instances_from_image_metadata
72 diffgram_input.task_id = task_id
73 diffgram_input.batch_id = batch_id
74 diffgram_input.video_parent_length = video_parent_length
75 diffgram_input.remove_link = remove_link
76 diffgram_input.add_link = add_link
77 diffgram_input.copy_instance_list = copy_instance_list
78 diffgram_input.external_map_id = external_map_id
79 diffgram_input.original_filename = original_filename

Callers 3

execute_actionMethod · 0.90

Calls 7

InputClass · 0.90
UploadClass · 0.90
PrioritizedItemClass · 0.90
routerMethod · 0.80
getMethod · 0.45
addMethod · 0.45

Tested by

no test coverage detected