Commit 019bd00d authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

fix indent for if-else use_detector

parent b2450a56
...@@ -116,29 +116,27 @@ class GeneralDAGViaObsid(BaseDAG): ...@@ -116,29 +116,27 @@ class GeneralDAGViaObsid(BaseDAG):
) )
assert this_update.success, this_update.message assert this_update.success, this_update.message
# generate DAG messages via obs_id # generate DAG messages via obs_id
else: else:
u_obsid, c_obsid = np.unique( u_obsid, c_obsid = np.unique(
[this_rec["obs_id"] for this_rec in recs.data], [this_rec["obs_id"] for this_rec in recs.data],
return_counts=True, return_counts=True,
)
# select those obs_ids with `counts == effective detector number`
u_obsid_selected = u_obsid[c_obsid == len(self.effective_detector_names)]
for this_obsid in u_obsid[u_obsid_selected]:
# generate a DAG message if is_selected
this_dag_run = self.gen_dag_run(
dag_group_run=dag_group_run,
dag_run=self.generate_sha1(),
batch_id=batch_id,
pmapname=pmapname,
dataset=dataset,
obs_type=obs_type,
obs_group=obs_group,
obs_id=this_obsid,
) )
# select those obs_ids with `counts == effective detector number` dag_run_list.append(this_dag_run)
u_obsid_selected = u_obsid[
c_obsid == len(self.effective_detector_names)
]
for this_obsid in u_obsid[u_obsid_selected]:
# generate a DAG message if is_selected
this_dag_run = self.gen_dag_run(
dag_group_run=dag_group_run,
dag_run=self.generate_sha1(),
batch_id=batch_id,
pmapname=pmapname,
dataset=dataset,
obs_type=obs_type,
obs_group=obs_group,
obs_id=this_obsid,
)
dag_run_list.append(this_dag_run)
if not demo: if not demo:
# push and update # push and update
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment