diff --git a/feedstock/recipe.py b/feedstock/recipe.py index 2d266b3..46cde60 100644 --- a/feedstock/recipe.py +++ b/feedstock/recipe.py @@ -1,12 +1,13 @@ -import xarray as xr -import apache_beam as beam -import xarray_beam as xbeam -import argparse -from apache_beam.options.pipeline_options import PipelineOptions -from apache_beam.options.pipeline_options import SetupOptions def run(argv=None, save_main_session=True): + import xarray as xr + import apache_beam as beam + import xarray_beam as xbeam + import argparse + + from apache_beam.options.pipeline_options import PipelineOptions + from apache_beam.options.pipeline_options import SetupOptions """Main entry point; defines and runs the wordcount pipeline.""" parser = argparse.ArgumentParser()