async fn handle_publish(
        &self,
        from_agent: AgentPubKey,
        request_validation_receipt: bool,
        _sgd_hash: ai_hash::AnySgdHash,
        ops: Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>,
    ) -> CellResult<()> {
        incoming_sgd_ops_workflow(
            &self.env,
            self.queue_triggers.sys_validation.clone(),
            ops,
            Some(from_agent),
            request_validation_receipt,
        )
        .await
        .map_err(Box::new)
        .map_err(ConductorApiError::from)
        .map_err(Box::new)?;
        Ok(())
    }
/// we are receiving a "publish" event from the network
we are receiving a "publish" event from the network
we are receiving a " publish " event from the network
async fn handle_publish(
        &self,
        from_agent: AgentPubKey,
        request_validation_receipt: bool,
        _sgd_hash: ai_hash::AnySgdHash,
        ops: Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>,
    ) -> CellResult<()> {
        incoming_sgd_ops_workflow(
            &self.env,
            self.queue_triggers.sys_validation.clone(),
            ops,
            Some(from_agent),
            request_validation_receipt,
        )
        .await
        .map_err(Box::new)
        .map_err(ConductorApiError::from)
        .map_err(Box::new)?;
        Ok(())
    }
async fn handle_publish ( & self , from_agent : AgentPubKey , request_validation_receipt : bool , _sgd_hash : ai_hash :: AnySgdHash , ops : Vec < ( ai_hash :: SgdOpHash , aingle_types :: sgd_op :: SgdOp ) > , ) -> CellResult < ( ) > { incoming_sgd_ops_workflow ( & self . env , self . queue_triggers . sys_validation . clone ( ) , ops , Some ( from_agent ) , request_validation_receipt , ) . await . map_err ( Box :: new ) . map_err ( ConductorApiError :: from ) . map_err ( Box :: new ) ? ; Ok ( ( ) ) }
we are receiving a "publish" event from the network
we are receiving a " publish " event from the network
&self
from_agent
AgentPubKey
request_validation_receipt
bool
_sgd_hash
ai_hash::AnySgdHash
ops
Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>
&self
from_agent
AgentPubKey
request_validation_receipt
bool
_sgd_hash
ai_hash::AnySgdHash
ops
Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>