[FSTORE-1160] Remove wait_for_job in all tutorials (#232)

Remove wait_for_job in all tutorials

Author: Maxxx-zh

advanced_tutorials/air_quality/1_air_quality_feature_backfill.ipynb

@@ -626,10 +626,7 @@
    "outputs": [],
    "source": [
     "# Insert data\n",
-    "weather_fg.insert(\n",
-    "    df_weather, \n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "weather_fg.insert(df_weather)"
    ]
   },
   {

advanced_tutorials/bitcoin/1_bitcoin_feature_backfill.ipynb

@@ -382,10 +382,7 @@
     "    event_time='unix',\n",
     ")\n",
     "\n",
-    "tweets_vader_fg.insert(\n",
-    "    tweets_vader,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "tweets_vader_fg.insert(tweets_vader)"
    ]
   },
   {
@@ -417,7 +414,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.9.12"
+   "version": "3.9.18"
   }
  },
  "nbformat": 4,

advanced_tutorials/bitcoin/2_bitcoin_feature_pipeline.ipynb

@@ -504,7 +504,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "tweets_vader_fg.insert(tweets_vader_batch, wait=True)"
+    "tweets_vader_fg.insert(tweets_vader_batch)"
    ]
   },
   {
@@ -536,7 +536,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.9.12"
+   "version": "3.9.18"
   }
  },
  "nbformat": 4,

advanced_tutorials/citibike/1_citibike_feature_backfill.ipynb

@@ -514,10 +514,7 @@
    },
    "outputs": [],
    "source": [
-    "citibike_usage_fg.insert(\n",
-    "    df_enhanced,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "citibike_usage_fg.insert(df_enhanced)"
    ]
   },
   {
@@ -546,10 +543,7 @@
    },
    "outputs": [],
    "source": [
-    "citibike_stations_info_fg.insert(\n",
-    "    df_stations_info,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "citibike_stations_info_fg.insert(df_stations_info)"
    ]
   },
   {
@@ -575,10 +569,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "us_holidays_fg.insert(\n",
-    "    df_holidays,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "us_holidays_fg.insert(df_holidays)"
    ]
   },
   {
@@ -606,10 +597,7 @@
    },
    "outputs": [],
    "source": [
-    "meteorological_measurements_fg.insert(\n",
-    "    df_weather, \n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "meteorological_measurements_fg.insert(df_weather)"
    ]
   },
   {
@@ -643,7 +631,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.9.12"
+   "version": "3.9.18"
   }
  },
  "nbformat": 4,

advanced_tutorials/citibike/2_citibike_feature_pipeline.ipynb

@@ -321,10 +321,7 @@
    "outputs": [],
    "source": [
     "# Insert new data\n",
-    "meteorological_measurements_fg.insert(\n",
-    "    df_weather_batch,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "meteorological_measurements_fg.insert(df_weather_batch)"
    ]
   },
   {

advanced_tutorials/credit_scores/1_credit_scores_feature_backfill.ipynb

@@ -433,10 +433,7 @@
     "    online_enabled=False,\n",
     "    event_time='datetime',\n",
     ")\n",
-    "applications_fg.insert(\n",
-    "    applications_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "applications_fg.insert(applications_df)"
    ]
   },
   {
@@ -460,10 +457,7 @@
     "    primary_key=['sk_id_bureau'],\n",
     "    online_enabled=False,\n",
     ")\n",
-    "bureau_balances_fg.insert(\n",
-    "    bureau_balances_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "bureau_balances_fg.insert(bureau_balances_df)"
    ]
   },
   {
@@ -488,10 +482,7 @@
     "    online_enabled=False,\n",
     "    event_time='datetime',\n",
     ")\n",
-    "bureaus_fg.insert(\n",
-    "    bureaus_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "bureaus_fg.insert(bureaus_df)"
    ]
   },
   {
@@ -516,10 +507,7 @@
     "    online_enabled=False,\n",
     "    event_time='datetime',\n",
     ")\n",
-    "previous_applications_fg.insert(\n",
-    "    previous_applications_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "previous_applications_fg.insert(previous_applications_df)"
    ]
   },
   {
@@ -571,10 +559,7 @@
     "    online_enabled=False,\n",
     "    event_time='datetime',\n",
     ")\n",
-    "installment_payments_fg.insert(\n",
-    "    installment_payments_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "installment_payments_fg.insert(installment_payments_df)"
    ]
   },
   {
@@ -598,10 +583,7 @@
     "    primary_key=['sk_id_prev','sk_id_curr'],\n",
     "    online_enabled=False,\n",
     ")\n",
-    "credit_card_balances_fg.insert(\n",
-    "    credit_card_balances_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "credit_card_balances_fg.insert(credit_card_balances_df)"
    ]
   },
   {
@@ -626,10 +608,7 @@
     "    online_enabled=False,\n",
     ")\n",
     "\n",
-    "previous_loan_counts_fg.insert(\n",
-    "    previous_loan_counts,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "previous_loan_counts_fg.insert(previous_loan_counts)"
    ]
   },
   {
@@ -908,7 +887,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.9.12"
+   "version": "3.9.18"
   }
  },
  "nbformat": 4,

advanced_tutorials/credit_scores/2_credit_scores_feature_pipeline.ipynb

@@ -397,10 +397,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "bureau_balances_fg.insert(\n",
-    "    bureau_balances_df_generated,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "bureau_balances_fg.insert(bureau_balances_df_generated)"
    ]
   },
   {
@@ -410,10 +407,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "bureaus_fg.insert(\n",
-    "    bureaus_df_generated, \n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "bureaus_fg.insert(bureaus_df_generated)"
    ]
   },
   {
@@ -423,10 +417,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "credit_card_balances_fg.insert(\n",
-    "    credit_card_balances_df_generated,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "credit_card_balances_fg.insert(credit_card_balances_df_generated)"
    ]
   },
   {
@@ -436,7 +427,10 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "installment_payments_fg.insert(installment_payments_df_generated)"
+    "installment_payments_fg.insert(\n",
+    "    installment_payments_df_generated,\n",
+    "    write_options={\"wait_for_job\": True},\n",
+    ")"
    ]
   },
   {
@@ -446,10 +440,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "pos_cash_balances_fg.insert(\n",
-    "    pos_cash_balances_df_generated,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "pos_cash_balances_fg.insert(pos_cash_balances_df_generated)"
    ]
   },
   {
@@ -469,10 +460,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "previous_loan_counts_fg.insert(\n",
-    "    previous_loan_counts_df_generated,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "previous_loan_counts_fg.insert(previous_loan_counts_df_generated)"
    ]
   },
   {

advanced_tutorials/electricity/1_electricity_feature_backfill.ipynb

@@ -275,10 +275,7 @@
    },
    "outputs": [],
    "source": [
-    "meteorological_measurements_fg.insert(\n",
-    "    meteorological_measurements_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "meteorological_measurements_fg.insert(meteorological_measurements_df)"
    ]
   },
   {
@@ -309,10 +306,7 @@
    },
    "outputs": [],
    "source": [
-    "electricity_prices_fg.insert(\n",
-    "    electricity_prices_df,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "electricity_prices_fg.insert(electricity_prices_df)"
    ]
   },
   {
@@ -342,10 +336,7 @@
    },
    "outputs": [],
    "source": [
-    "swedish_holidays_fg.insert(\n",
-    "    holidays_df, \n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "swedish_holidays_fg.insert(holidays_df)"
    ]
   },
   {
@@ -382,7 +373,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.9.12"
+   "version": "3.9.18"
   }
  },
  "nbformat": 4,

advanced_tutorials/electricity/2_electricity_feature_pipeline.ipynb

@@ -185,10 +185,7 @@
    "outputs": [],
    "source": [
     "# Insert data\n",
-    "electricity_prices_fg.insert(\n",
-    "    electricity_prices_df, \n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "electricity_prices_fg.insert(electricity_prices_df)"
    ]
   },
   {

advanced_tutorials/nyc_taxi_fares/1_nyc_taxi_fares_feature_backfill.ipynb

@@ -180,10 +180,7 @@
     "    statistics_config=True,\n",
     ")\n",
     "\n",
-    "rides_fg.insert(\n",
-    "    df_rides,\n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "rides_fg.insert(df_rides)"
    ]
   },
   {
@@ -210,10 +207,7 @@
     "    statistics_config=True,\n",
     ")   \n",
     "\n",
-    "fares_fg.insert(\n",
-    "    df_fares, \n",
-    "    write_options={\"wait_for_job\": True},\n",
-    ")"
+    "fares_fg.insert(df_fares)"
    ]
   },
   {