wip

leap-stc · Sep 11, 2024 · edc2b2d · edc2b2d
1 parent 1af518f
commit edc2b2d
Showing 1 changed file with 7 additions and 6 deletions.
diff --git 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()