Loading raps/dataloaders/marconi100.py +6 −3 Original line number Diff line number Diff line Loading @@ -207,9 +207,12 @@ def load_data_from_df(jobs_df: pd.DataFrame, **kwargs): if gpu_trace.size > 0 and (jid == job_id or jid == '*'): # and time_submit >= 0: job_info = job_dict(nodes_required, name, account, cpu_trace, gpu_trace, [], [], end_state, scheduled_nodes, job_id, priority, partition, job_info = job_dict(nodes_required=nodes_required, name=name, account=account, cpu_trace=cpu_trace, gpu_trace=gpu_trace, nrx_trace=[],ntx_trace=[], end_state=end_state, scheduled_nodes=scheduled_nodes, id=job_id, priority=priority,partition=partition, submit_time=submit_time, time_limit=time_limit, start_time=start_time, end_time=end_time, wall_time=wall_time, trace_time=trace_time, Loading Loading
raps/dataloaders/marconi100.py +6 −3 Original line number Diff line number Diff line Loading @@ -207,9 +207,12 @@ def load_data_from_df(jobs_df: pd.DataFrame, **kwargs): if gpu_trace.size > 0 and (jid == job_id or jid == '*'): # and time_submit >= 0: job_info = job_dict(nodes_required, name, account, cpu_trace, gpu_trace, [], [], end_state, scheduled_nodes, job_id, priority, partition, job_info = job_dict(nodes_required=nodes_required, name=name, account=account, cpu_trace=cpu_trace, gpu_trace=gpu_trace, nrx_trace=[],ntx_trace=[], end_state=end_state, scheduled_nodes=scheduled_nodes, id=job_id, priority=priority,partition=partition, submit_time=submit_time, time_limit=time_limit, start_time=start_time, end_time=end_time, wall_time=wall_time, trace_time=trace_time, Loading