20

I'm using the example code on elastic search's blog post about their new crate and I'm unable to get it working as intended. The thread panics with thread 'main' panicked at 'not currently running on the Tokio runtime.'.

What is the Tokio runtime, how do I configure it and why must I?

use futures::executor::block_on;

async elastic_search_example() -> Result<(), Box<dyn Error>> {
    let index_response = client
        .index(IndexParts::IndexId("tweets", "1"))
        .body(json!({
            "user": "kimchy",
            "post_date": "2009-11-15T00:00:00Z",
            "message": "Trying out Elasticsearch, so far so good?"
        }))
        .refresh(Refresh::WaitFor)
        .send()
        .await?;
    if !index_response.status_code().is_success() {
        panic!("indexing document failed")
    }
    let index_response = client
        .index(IndexParts::IndexId("tweets", "2"))
        .body(json!({
            "user": "forloop",
            "post_date": "2020-01-08T00:00:00Z",
            "message": "Indexing with the rust client, yeah!"
        }))
        .refresh(Refresh::WaitFor)
        .send()
        .await?;
    if !index_response.status_code().is_success() {
        panic!("indexing document failed")
    }
}

fn main() {
    block_on(elastic_search_example());
}
Shepmaster
  • 388,571
  • 95
  • 1,107
  • 1,366
Miranda Abbasi
  • 521
  • 2
  • 5
  • 10

2 Answers2

18

It looks like Elasticsearch's crate is using Tokio internally, so you must use it too to match their assumptions.

Looking for block_on function in their documentation, I've got this. So, it appears that your main should look like this:

use tokio::runtime::Runtime;

fn main() {
    Runtime::new()
        .expect("Failed to create Tokio runtime")
        .block_on(elastic_search_example());
}

Or you can make you main function itself async with the attribute macro, which will generate runtime creation and block_on call for you:

#[tokio::main]
async fn main() {
    elastic_search_example().await;
}
Cerberus
  • 8,879
  • 1
  • 25
  • 40
  • That clarifies a lot. Thank you. – Miranda Abbasi Jan 16 '20 at 16:02
  • Using the second approach not compiles, it give these two errors: error[E0277]: `main` has invalid return type `impl futures::Future` --> src\main.rs:110:17 | 110 | async fn main() { | ^ `main` can only return types that implement `Termination` | = help: consider using `()`, or a `Result` error[E0752]: `main` function is not allowed to be `async` --> src\main.rs:110:1 | 110 | async fn main() { | ^^^^^^^^^^^^^^^ `main` function is not allowed to be `async` – Dani P. Feb 28 '21 at 11:23
  • Please ask new question with your real code and real error, since you're either not using the exact same code as in the example or not showing the full error you get. – Cerberus Feb 28 '21 at 11:54
7

I had the same error when I used to tokio::run (from tokio version = 0.1) with crate that use tokio02 (tokio version = 0.2) internally (in my case it was reqwest). First I just changed std::future::Future to futures01::future::Future with futures03::compat. To make it compile. After run I get exactly your error.

Solution:

Adding tokio-compat resolved my problem.

More about tokio compat

S.R
  • 2,411
  • 1
  • 22
  • 33