(session, task, job, log)
| 15 | logger = get_shared_logger() |
| 16 | |
| 17 | def trigger_task_complete_sync_event(session, task, job, log): |
| 18 | sync_event_manager = SyncEventManager.create_sync_event_and_manager( |
| 19 | session = session, |
| 20 | dataset_source_id = None, |
| 21 | dataset_destination = None, |
| 22 | description = None, |
| 23 | file = task.file, |
| 24 | job = task.job, |
| 25 | input = None, |
| 26 | project = task.job.project, |
| 27 | created_task = None, |
| 28 | completed_task = task, |
| 29 | new_file_copy = None, |
| 30 | transfer_action = None, |
| 31 | event_effect_type = '', |
| 32 | event_trigger_type = 'task_completed', |
| 33 | status = 'init', |
| 34 | member_created = None |
| 35 | ) |
| 36 | logger.debug(f"Created sync_event {sync_event_manager.sync_event.id}") |
| 37 | if job.completion_directory and job.output_dir_action in ['copy', 'move']: |
| 38 | job_observable = task_file_observers.JobObservable(session = session, |
| 39 | log = log, |
| 40 | job = job, |
| 41 | task = task, |
| 42 | sync_events_manager = sync_event_manager) |
| 43 | job_observable.notify_all_observers(defer = True) |
| 44 | |
| 45 | Event.new_deferred( |
| 46 | session = session, |
| 47 | kind = 'task_completed', |
| 48 | project_id = task.project_id, |
| 49 | member_id = get_member(session).id if get_member(session) else None, |
| 50 | task_id = task.id, |
| 51 | wait_for_commit = True |
| 52 | ) |
| 53 | |
| 54 | |
| 55 |
no test coverage detected