fixed bug in dispatch_file (028ad8b5) · Commits · csst-cicd / csst-dag

csst_dag/dag/_dispatcher.py

+16 −2

Original line number	Diff line number	Diff line
		@@ -249,10 +249,24 @@ class Dispatcher:
		this_task = dict(data_basis[i_data_basis])
		this_data_basis = data_basis[i_data_basis : i_data_basis + 1]
		this_relevant_plan = table.join(
		this_data_basis,
		this_data_basis[
		"dataset",
		"instrument",
		"obs_type",
		"obs_group",
		"obs_id",
		"n_frame",
		],
		plan_basis,
		keys=["dataset", "obs_id"],
		keys=[
		"dataset",
		"instrument",
		"obs_type",
		"obs_group",
		"obs_id",
		],
		join_type="inner",
		table_names=["data", "plan"],
		)
		# append this task
		task_list.append(