Skip to content

Commit

Permalink
refactor: move src/tests/ to tests/
Browse files Browse the repository at this point in the history
  • Loading branch information
laysakura committed Apr 10, 2023
1 parent 28b838e commit b4ded1a
Show file tree
Hide file tree
Showing 5 changed files with 15 additions and 38 deletions.
2 changes: 0 additions & 2 deletions sdks/rust/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,5 @@ pub mod runners;
pub mod transforms;
pub mod worker;

mod tests;

#[macro_use]
extern crate strum_macros;
21 changes: 0 additions & 21 deletions sdks/rust/src/tests/mod.rs

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

#[cfg(test)]
mod tests {
use crate::{
use apache_beam::{
coders::{
coder_resolver::{
BytesCoderResolverDefault, CoderResolver, StrUtf8CoderResolverDefault,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,17 +20,17 @@
mod tests {
use std::sync::Arc;

use crate::elem_types::kv::KV;
use crate::internals::pipeline::Pipeline;
use crate::internals::pvalue::{PType, PValue};
use crate::runners::direct_runner::DirectRunner;
use crate::runners::runner::RunnerI;
use crate::transforms::create::Create;
use crate::transforms::flatten::Flatten;
use crate::transforms::group_by_key::GroupByKey;
use crate::transforms::impulse::Impulse;
use crate::transforms::pardo::ParDo;
use crate::transforms::testing::AssertEqualUnordered;
use apache_beam::elem_types::kv::KV;
use apache_beam::internals::pipeline::Pipeline;
use apache_beam::internals::pvalue::{PType, PValue};
use apache_beam::runners::direct_runner::DirectRunner;
use apache_beam::runners::runner::RunnerI;
use apache_beam::transforms::create::Create;
use apache_beam::transforms::flatten::Flatten;
use apache_beam::transforms::group_by_key::GroupByKey;
use apache_beam::transforms::impulse::Impulse;
use apache_beam::transforms::pardo::ParDo;
use apache_beam::transforms::testing::AssertEqualUnordered;

#[tokio::test]
async fn run_direct_runner() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,13 +22,13 @@ mod tests {

use serde_json;

use crate::internals::urns;
use crate::proto::beam_api::{
use apache_beam::internals::urns;
use apache_beam::proto::beam_api::{
fn_execution::ProcessBundleDescriptor,
pipeline::{FunctionSpec, PTransform},
};

use crate::{
use apache_beam::{
worker::sdk_worker::BundleProcessor,
worker::test_utils::{reset_log, RECORDING_OPERATOR_LOGS},
};
Expand Down

0 comments on commit b4ded1a

Please sign in to comment.