pub async fn submit_wf(
        &self,
        workflow_id: impl Into<String>,
        workflow_type: impl Into<String>,
        input: Vec<Payload>,
        options: WorkflowOptions,
    ) -> Result<String, anyhow::Error> {
        self.incr_expected_run_count(1);
        if let Some(c) = self.client.as_ref() {
            let wfid = workflow_id.into();
            let res = c
                .start_workflow(
                    input,
                    self.inner.task_queue().to_string(),
                    wfid.clone(),
                    workflow_type.into(),
                    options,
                )
                .await?;
            Ok(res.run_id)
        } else {
            Ok("fake_run_id".to_string())
        }
    }
/// Create a workflow, asking the server to start it with the provided workflow ID and using the
/// provided workflow function.
///
/// Increments the expected Workflow run count.
///
/// Returns the run id of the started workflow
Create a workflow, asking the server to start it with the provided workflow ID and using the
provided workflow function.

Increments the expected Workflow run count.

Returns the run id of the started workflow
Create a workflow asking the server to start it with the provided workflow ID and using the provided workflow function . Increments the expected Workflow run count . Returns the run id of the started workflow
pub async fn submit_wf(
        &self,
        workflow_id: impl Into<String>,
        workflow_type: impl Into<String>,
        input: Vec<Payload>,
        options: WorkflowOptions,
    ) -> Result<String, anyhow::Error> {
        self.incr_expected_run_count(1);
        if let Some(c) = self.client.as_ref() {
            let wfid = workflow_id.into();
            let res = c
                .start_workflow(
                    input,
                    self.inner.task_queue().to_string(),
                    wfid.clone(),
                    workflow_type.into(),
                    options,
                )
                .await?;
            Ok(res.run_id)
        } else {
            Ok("fake_run_id".to_string())
        }
    }
pub async fn submit_wf ( & self , workflow_id : impl Into < String > , workflow_type : impl Into < String > , input : Vec < Payload > , options : WorkflowOptions , ) -> Result < String , anyhow :: Error > { self . incr_expected_run_count ( 1 ) ; if let Some ( c ) = self . client . as_ref ( ) { let wfid = workflow_id . into ( ) ; let res = c . start_workflow ( input , self . inner . task_queue ( ) . to_string ( ) , wfid . clone ( ) , workflow_type . into ( ) , options , ) . await ? ; Ok ( res . run_id ) } else { Ok ( " " . to_string ( ) ) } }
Create a workflow, asking the server to start it with the provided workflow ID and using the
provided workflow function.
Create a workflow asking the server to start it with the provided workflow ID and using the provided workflow function .
&self
workflow_id
impl Into<String>
workflow_type
impl Into<String>
input
Vec<Payload>
options
WorkflowOptions
&self
workflow_id
impl Into<String>
workflow_type
impl Into<String>
input
Vec<Payload>
options
WorkflowOptions